public static < T > ReactiveSeq < T > connectToReactiveSeq ( Observable < T > observable ) { return Spouts . async ( s -> { observable . subscribe ( s :: onNext , e -> { s . onError ( e ) ; s . onComplete ( ) ; } , s :: onComplete ) ; } ) ; }
Convert an Observable to a cyclops - react ReactiveSeq