// Typical usage: subscribe for a filtered event by matching on CorrelationId,
 // process only one event, and omit the callback and cancellation token.
 async {
     let targetId = some-correlation-id
     // Here, take is set to 1 and no callback or cancellation token is provided.
     let! subscription = query.Subscribe((fun event -> event.CorrelationId = targetId), 1)
     // Use the asynchronous subscription as needed.
 } |> Async.Start

val async: AsyncBuilder

val targetId: (obj -> obj)

val id: x: 'T -> 'T

val subscription: 'a

val query: Linq.QueryBuilder

Multiple items
type Async = static member AsBeginEnd: computation: ('Arg -> Async<'T>) -> ('Arg * AsyncCallback * obj -> IAsyncResult) * (IAsyncResult -> 'T) * (IAsyncResult -> unit) static member AwaitEvent: event: IEvent<'Del,'T> * ?cancelAction: (unit -> unit) -> Async<'T> (requires delegate and 'Del :> Delegate) static member AwaitIAsyncResult: iar: IAsyncResult * ?millisecondsTimeout: int -> Async<bool> static member AwaitTask: task: Task<'T> -> Async<'T> + 1 overload static member AwaitWaitHandle: waitHandle: WaitHandle * ?millisecondsTimeout: int -> Async<bool> static member CancelDefaultToken: unit -> unit static member Catch: computation: Async<'T> -> Async<Choice<'T,exn>> static member Choice: computations: Async<'T option> seq -> Async<'T option> static member FromBeginEnd: beginAction: (AsyncCallback * obj -> IAsyncResult) * endAction: (IAsyncResult -> 'T) * ?cancelAction: (unit -> unit) -> Async<'T> + 3 overloads static member FromContinuations: callback: (('T -> unit) * (exn -> unit) * (OperationCanceledException -> unit) -> unit) -> Async<'T> ...

--------------------
type Async<'T>

static member Async.Start: computation: Async<unit> * ?cancellationToken: System.Threading.CancellationToken -> unit

 // Example usage: subscribe to all events and write them to the console.
 let subscription =
     query.Subscribe((fun event -> printfn "Received event: %A" event))

 // Later, to cancel the subscription:
 subscription.Dispose()

val subscription: obj

val query: Linq.QueryBuilder

val printfn: format: Printf.TextWriterFormat<'T> -> 'T