package Ġcom . lifecycle . rx . observer Ċ Ċ import Ġio . reactivex . Observer Ċ import Ġio . reactivex . dis pos ables . Disposable ĊĊ Ċ /** Ċ Ġ* ĠCompany : Ċ Ġ* ĠDescription : Ċ Ġ* ĠAuthor : Ġcreated Ġby ĠA rv in W ang Ġon Ġ 2 0 1 9 / 1 0 / 1 7 Ġ 1 7 : 3 9 Ċ Ġ* ĠEmail : Ġ 1 0 3 3 1 4 4 2 9 4 @ qq . com Ċ Ġ*/ Ċ class ĠLambda Observer < T >( ĊĠĠĠ Ġprivate Ġval Ġon Next : Ġ( T ) Ġ-> ĠUnit , ĊĠĠĠ Ġprivate Ġval ĠonError : Ġ( Throwable ) Ġ-> ĠUnit , ĊĠĠĠ Ġprivate Ġval ĠonComplete : Ġ() Ġ-> ĠUnit , ĊĠĠĠ Ġprivate Ġval Ġon Subscribe : Ġ( Disposable ) Ġ-> ĠUnit Ċ ) Ġ: ĠObserver < T > Ġ{ ĊĠĠĠ Ġoverride Ġfun ĠonComplete () Ġ{ ĊĠĠĠĠĠĠĠ ĠonComplete . invoke () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Subscribe ( d : ĠDis posable ) Ġ{ ĊĠĠĠĠĠĠĠ Ġon Subscribe . invoke ( d ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Next ( t : ĠT ) Ġ{ ĊĠĠĠĠĠĠĠ Ġon Next . invoke ( t ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠonError ( e : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠ ĠonError . invoke ( e ) ĊĠĠĠ Ġ} Ċ }