Rocket.jl

Rocket.jl copied to clipboard

Use Julia 1.10 for tests

1

This PR adds Julia 1.10 to the test set

bvdmitri

Here is minimum working example: ```julia subject = Subject(Int) paired = subject |> pairwise() subscribe!(paired, logger("paired")) for i = 1:10 @async next!(subject, i) end ``` output ``` [paired] Data: (1,...

zsoerenm

Is there a way to wait explicitly for the next value, like `take!` is doing it on Channels

3

Hi there, it would be nice to make `take!` also work on Rocket.jl observables. Something like the following ```julia function take!(datastream::Subscribable) c = Channel(1) subscribe(datastream, lambda(on_next=d -> put!(c, d) )...

schlichtanders