package Ġorg . not ests . rx test utils Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġj ur aj Ġon Ġ 1 2 / 1 1 / 2 0 1 7 . Ċ Ġ*/ Ċ sealed Ġclass ĠEvent < T > Ġ{ ĊĠĠĠ Ġdata Ġclass ĠSub scribed < T >( val Ġvalue : ĠT ) Ġ: ĠEvent < T >() ĊĠĠĠ Ġdata Ġclass ĠNext < T >( val Ġvalue : ĠT ) Ġ: ĠEvent < T >() ĊĠĠĠ Ġdata Ġclass ĠError < T >( val Ġerror : ĠThrowable ) Ġ: ĠEvent < T >() ĊĠĠĠ Ġobject ĠCompleted Ġ: ĠEvent < Unit >() Ċ } Ċ Ċ data Ġclass ĠRe corded < out ĠT >( val Ġdelay : ĠLong , Ġval Ġvalue : ĠT ) Ċ Ċ fun Ġ< T > Ġnext ( delay : ĠLong , Ġvalue : ĠT ) Ġ= ĠRe corded ( delay , ĠEvent . Next ( value )) Ċ fun Ġ< T > Ġerror ( delay : ĠLong , Ġerror : ĠThrowable ): ĠRe corded < Event < T >> Ġ= ĠRe corded ( delay , ĊĠĠĠĠĠĠĠ ĠEvent . Error ( error )) Ċ Ċ fun Ġcomplete ( delay : ĠLong ): ĠRe corded < Event < Unit >> Ġ= ĠRe corded ( delay , ĠEvent . Completed ) Ċ