/* Ċ Ġ* ĠÂ© Ġ 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 Adapter Ċ import Ġcom . t inder . sc ar let . utils . getRaw Type Ċ import Ġrx . Observable Ċ import Ġjava . lang . reflect . Type Ċ Ċ /** Ċ Ġ* ĠA Ġ[ stream Ġadapter Ġfactory ][ Stream Adapter . Factory ] Ġthat Ġuses ĠRx Java . Ċ Ġ*/ Ċ class ĠRx Java Stream Adapter Factory Ġ: ĠStream Adapter . Factory Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġcreate ( type : ĠType ): ĠStream Adapter < Any , ĠAny > Ġ= Ġwhen Ġ( type . getRaw Type ()) Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable :: class . java Ġ-> ĠObservable Stream Adapter () ĊĠĠĠĠĠĠĠ Ġelse Ġ-> Ġthrow ĠIllegalArgumentException () ĊĠĠĠ Ġ} Ċ } Ċ