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