public static < T > Observable < T > toObservable ( final FutureProvider < T > provider ) { return Observable . create ( new FutureProviderToStreamHandler <> ( provider ) ) ; }
creates new observable given future provider translating the future results into stream . the sequence will be evaluated on subscribe .