Publish Operators
Rocket.publish — Functionpublish(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }publish() is a shortcut for multicast(SubjectFactory())
See also: AbstractOperator, multicast, SubjectFactory
Rocket.publish_behavior — Functionpublish_behavior(default; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }publish_behavior(default) is a shortcut for multicast(BehaviorSubjectFactory(default))
See also: AbstractOperator, multicast, BehaviorSubjectFactory
Rocket.publish_replay — Functionpublish_replay(size::Int; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }publish_replay(size) is a shortcut for multicast(ReplaySubjectFactory(size))
See also: AbstractOperator, multicast, ReplaySubjectFactory
Rocket.publish_recent — Functionpublish_recent(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }publish_recent(size) is a shortcut for multicast(RecentSubjectFactory())
See also: AbstractOperator, multicast, RecentSubjectFactory