Moved RX to use new getStreamFromStream function