-
Notifications
You must be signed in to change notification settings - Fork 19
/
share.jl
30 lines (21 loc) · 1.26 KB
/
share.jl
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
export share
export share_replay
export share_recent
"""
share(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }
`share()` is a shortcut for `publish() + ref_count()`
See also: [`AbstractOperator`](@ref), [`multicast`](@ref), [`publish`](@ref), [`ref_count`](@ref)
"""
share(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler } = publish(scheduler = scheduler) + ref_count()
"""
share_replay(size::Int; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }
`share_replay(size)` is a shortcut for `publish_replay(size) + ref_count()`
See also: [`AbstractOperator`](@ref), [`multicast`](@ref), [`publish`](@ref), [`publish_replay`](@ref), [`ref_count`](@ref)
"""
share_replay(size::Int; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler } = publish_replay(size, scheduler = scheduler) + ref_count()
"""
share_recent(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler }
`share_recent()` is a shortcut for `publish_recent() + ref_count()`
See also: [`AbstractOperator`](@ref), [`multicast`](@ref), [`publish`](@ref), [`publish_recent`](@ref), [`ref_count`](@ref)
"""
share_recent(; scheduler::H = AsapScheduler()) where { H <: AbstractScheduler } = publish_recent(scheduler = scheduler) + ref_count()