rxFromStream