I don’t know if this is the best title, but I’d really like to use Reactive.jl in an upcoming project where we stream data from a scientific instrument to our cluster for analysis. Using OnlineStats.jl for analysis and then programming decision making to control the instrument.
I’d like to use Reactive.jl for this. However, I don’t see any utility functions for interfacing with real incoming data streams. I was thinking something utilizing ZMQ (or lower-level Julia base sockets) and interfacing with various Julia structs like DataFrames or Timeseries. (I’d also like to use them for financial data streams eventually)
Has this already been done? Or am I just thinking of this in the wrong way? If not, I’m happy to contribute while I make/use them.