Function Observable

Rocket.make — Function

make(f::Function, type::Type{D})

Creation operator for the FunctionObservable.

Arguments

f: function to be invoked on subscription
type: type of data in observable

Examples

using Rocket

source = make(Int) do actor
    next!(actor, 0)
    complete!(actor)
end

subscription = subscribe!(source, logger());
unsubscribe!(subscription)
;

# output

[LogActor] Data: 0
[LogActor] Completed

using Rocket

source = make(Int) do actor
    next!(actor, 0)
    setTimeout(100) do
        next!(actor, 1)
        complete!(actor)
    end
end

subscription = subscribe!(source, logger())
unsubscribe!(subscription)
;

# output

[LogActor] Data: 0

source

Rocket.FunctionObservable — Type

FunctionObservable{D}(f::F)

FunctionObservable wraps a callback `f`, which is called when the Observable is initially subscribed to.
This function is given an Actor, to which new values can be nexted (with `next!(actor, data)`),
or an `error!` method can be called to raise an error, or `complete!` can be called to notify of a successful completion.

# Arguments
- `f::F`: function to be invoked on subscription

See also: [`Subscribable`](@ref), [`make`](@ref)

source