Fixed rxJava deprecation warnings
Internal Stream Connections are pipelined

JAVA-1293