diff --git a/Project.toml b/Project.toml index 234842216..ca4efdd4f 100644 --- a/Project.toml +++ b/Project.toml @@ -1,7 +1,7 @@ name = "Rocket" uuid = "df971d30-c9d6-4b37-b8ff-e965b2cb3a40" authors = ["Dmitri Bagaev "] -version = "1.5.0" +version = "1.6.0" [deps] DataStructures = "864edb3b-99cc-5e75-8d2d-829cb0a9cfe8" diff --git a/src/Rocket.jl b/src/Rocket.jl index c79f59ebd..802cf77ba 100644 --- a/src/Rocket.jl +++ b/src/Rocket.jl @@ -136,4 +136,8 @@ include("operators/override.jl") include("extensions/observable/single.jl") +# Extensions to the `getrecent` method +getrecent(observables::Tuple) = Rocket.getrecent.(observables) +getrecent(::Nothing) = nothing + end # module diff --git a/src/observable/combined_updates.jl b/src/observable/combined_updates.jl index 70756140d..1e97d8de6 100644 --- a/src/observable/combined_updates.jl +++ b/src/observable/combined_updates.jl @@ -93,6 +93,8 @@ end strategy :: G end +getrecent(observable::CombineLatestUpdatesObservable) = getrecent(observable.sources) + function on_subscribe!(observable::CombineLatestUpdatesObservable{S, G}, actor::A) where { S, G, A } wrapper = CombineLatestUpdatesActorWrapper(observable.sources, actor, observable.strategy)