package Ġdev team . rx Ċ Ċ import Ġorg . testng . Assert Ċ import Ġorg . testng . annotations . Test Ċ Ċ class ĠOb servers Test Ġ{ ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Implement On Next () Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠGiven ĊĠĠĠĠĠĠĠ Ġvar Ġvalue Ġ= Ġ 0 ĊĊĠĠĠĠĠĠĠ Ġ// ĠWhen ĊĠĠĠĠĠĠĠ Ġval Ġobserver Ġ= Ġobserver < Int > Ġ{ Ġv Ġ-> Ġvalue Ġ= Ġv Ġ} ĊĠĠĠĠĠĠĠ Ġobserver . onNext ( 9 9 ) ĊĊĠĠĠĠĠĠĠ Ġ// ĠThen ĊĠĠĠĠĠĠĠ ĠAssert . assertEquals ( value , Ġ 9 9 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Implement OnError () Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠGiven ĊĠĠĠĠĠĠĠ Ġvar Ġexception : ĠException ? Ġ= Ġnull ĊĊĠĠĠĠĠĠĠ Ġ// ĠWhen ĊĠĠĠĠĠĠĠ Ġval Ġsome Error Ġ= ĠException (" test ") ĊĠĠĠĠĠĠĠ Ġval Ġobserver Ġ= Ġobserver ({ Ġ_: Int Ġ-> ĠUnit }, Ġ{ Ġe : Exception Ġ-> Ġexception Ġ= Ġe Ġ}, Ġ{}) ĊĠĠĠĠĠĠĠ Ġobserver . onError ( some Error ) ĊĊĠĠĠĠĠĠĠ Ġ// ĠThen ĊĠĠĠĠĠĠĠ ĠAssert . assertEquals ( exception , Ġsome Error ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Implement On Complete () Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠGiven ĊĠĠĠĠĠĠĠ Ġvar Ġcompleted : ĠBoolean ? Ġ= Ġnull ĊĊĠĠĠĠĠĠĠ Ġ// ĠWhen ĊĠĠĠĠĠĠĠ Ġval Ġobserver Ġ= Ġobserver ({ Ġ_: Int Ġ-> ĠUnit }, Ġ{ ĠUnit Ġ}, Ġ{ Ġcompleted Ġ= Ġtrue Ġ}) ĊĠĠĠĠĠĠĠ Ġobserver . onComplete () ĊĊĠĠĠĠĠĠĠ Ġ// ĠThen ĊĠĠĠĠĠĠĠ ĠAssert . assertEquals ( completed , Ġtrue ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Convert Collection To Observer () Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠGiven ĊĠĠĠĠĠĠĠ Ġval Ġvalues Ġ= Ġmutable ListOf < Int >() ĊĊĠĠĠĠĠĠĠ Ġ// ĠWhen ĊĠĠĠĠĠĠĠ Ġval Ġobserver Ġ= Ġvalues . to Observer () ĊĠĠĠĠĠĠĠ Ġobserver . onNext ( 1 ) ĊĠĠĠĠĠĠĠ Ġobserver . onNext ( 2 ) ĊĠĠĠĠĠĠĠ Ġobserver . onComplete () ĊĊĠĠĠĠĠĠĠ Ġ// ĠThen ĊĠĠĠĠĠĠĠ ĠAssert . assertEquals ( values , ĠlistOf ( 1 , Ġ 2 )) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Dem aterial ize () Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠGiven ĊĠĠĠĠĠĠĠ Ġval Ġvalues Ġ= Ġmutable ListOf < Notification < Int >>() ĊĊĠĠĠĠĠĠĠ Ġ// ĠWhen ĊĠĠĠĠĠĠĠ Ġval Ġobserver Ġ= Ġvalues . to Observer (). de material ize () ĊĠĠĠĠĠĠĠ Ġobserver . onNext ( 1 ) ĊĠĠĠĠĠĠĠ Ġobserver . onNext ( 2 ) ĊĊĠĠĠĠĠĠĠ Ġ// ĠThen ĊĠĠĠĠĠĠĠ ĠAssert . assertEquals ( values , ĠlistOf ( Notification Next ( 1 ), ĠNotification Next ( 2 ))) ĊĠĠĠ Ġ} Ċ }