Async Operator

async(size::Int = typemax(Int))

Creates an async operator, which sends items from the source Observable asynchronously.

Arguments

• size: Asynchronous messages buffer size, default is a typemax(Int)

Producing

Stream of type <: Subscribable{L} where L refers to type of source stream

See also: AbstractOperator, InferableOperator, ProxyObservable