package Ġai . rot or . mobile Ċ Ċ import Ġio . reactivex . Comp letable Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Single Ċ import Ġio . reactivex . ob servers . Test Observer Ċ import Ġorg . junit . Before Ċ import Ġorg . junit . Test Ċ Ċ class ĠRx Tests Ġ{ ĊĠĠĠ Ġprivate Ġlateinit Ġvar Ġsubscriber : ĠTest Observer < String > ĊĊĠĠĠ Ġ@ Before ĊĠĠĠ Ġfun Ġsetup () Ġ{ ĊĠĠĠĠĠĠĠ Ġsubscriber Ġ= ĠTest Observer () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Observable Factory Error () Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable . error < String >( IllegalStateException ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĠĠĠĠĠĠĠ Ġsubscriber . assert Error ( IllegalStateException :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Single Factory Error () Ġ{ ĊĠĠĠĠĠĠĠ ĠSingle . error < String >( IllegalStateException ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĠĠĠĠĠĠĠ Ġsubscriber . assert Error ( IllegalStateException :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Comp letable Factory Error () Ġ{ ĊĠĠĠĠĠĠĠ ĠComp letable . error ( IllegalStateException ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĠĠĠĠĠĠĠ Ġsubscriber . assert Error ( IllegalStateException :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Observable Callable Error () Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable . from Callable Ġ{ Ġthrow ĠIllegalStateException () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĠĠĠĠĠĠĠ Ġsubscriber . assert Error ( IllegalStateException :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Single Callable Error () Ġ{ ĊĠĠĠĠĠĠĠ ĠSingle . from Callable Ġ{ Ġthrow ĠIllegalStateException () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĠĠĠĠĠĠĠ Ġsubscriber . assert Error ( IllegalStateException :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Comp letable Callable Error () Ġ{ ĊĠĠĠĠĠĠĠ ĠComp letable . from Callable Ġ{ Ġthrow ĠIllegalStateException () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĠĠĠĠĠĠĠ Ġsubscriber . assert Error ( IllegalStateException :: class . java ) ĊĠĠĠ Ġ} Ċ } Ċ