/* Ċ Ġ* ĠÂ© Ġ 2 0 1 8 ĠMatch ĠGroup , ĠLLC . Ċ Ġ*/ Ċ Ċ package Ġcom . t inder . sc ar let . stream adapter . rx java Ċ Ċ import Ġcom . t inder . sc ar let . Stream Ċ import Ġcom . t inder . sc ar let . Stream Adapter Ċ import Ġrx . Observable Ċ import Ġrx . Subscriber Ċ Ċ class ĠObservable Stream Adapter < T > Ġ: ĠStream Adapter < T , ĠObservable < T >> Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġadapt ( stream : ĠStream < T >): ĠObservable < T > Ġ= ĠObservable . unsafe Create ( Stream On Subscribe ( stream )) ĊĊĠĠĠ Ġprivate Ġclass ĠStream On Subscribe < T >( private Ġval Ġstream : ĠStream < T >) Ġ: ĠObservable . On Subscribe < T > Ġ{ ĊĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġcall ( subscriber : ĠSubscriber < in ĠT >) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġstream . start ( Stream Observer ( subscriber )) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġprivate Ġclass ĠStream Observer < in ĠR > Ġinternal Ġconstructor ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġsubscriber : ĠSubscriber < in ĠR > ĊĠĠĠĠĠĠĠ Ġ) Ġ: ĠStream . Observer < R > Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Next ( data : ĠR ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . onNext ( data ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonError ( throwable : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . onError ( throwable ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonComplete () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . on Completed () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ