Add tests for RX streams