I was going to ask this on Stackoverflow but it seems like reactive programming is split into per-language questions (RxJava, RxJS, RxRuby, etc.) and this is a more generic question.

How do you stream items from one Observable to multiple Observers?

I have a stream of CSV items, they're mapped to a dictionary/hash table, and then I want to:

• get the maximum value from this stream
• process the stream in a different way
• sample the stream

Can I call subscribe multiple times and then call the other operators?