package Ġcom . q ing me i 2 . rx schedul ers _ support _ kt Ċ Ċ import Ġcom . q ing me i 2 . rx schedul ers . Rx Scheduler Provider Ċ import Ġcom . q ing me i 2 . rx schedul ers . Rx Scheduler Transformer Ċ import Ġio . reactivex .* Ċ Ċ fun Ġ< T > ĠObservable < T >. switch Thread (): ĠObservable < T > Ġ= ĊĠĠĠĠĠĠĠ Ġcompose ( Rx Scheduler Transformer ()) Ċ Ċ fun Ġ< T > ĠFlow able < T >. switch Thread (): ĠFlow able < T > Ġ= ĊĠĠĠĠĠĠĠ Ġcompose ( Rx Scheduler Transformer ()) Ċ Ċ fun Ġ< T > ĠSingle < T >. switch Thread (): ĠSingle < T > Ġ= ĊĠĠĠĠĠĠĠ Ġcompose ( Rx Scheduler Transformer ()) Ċ Ċ fun Ġ< T > ĠMaybe < T >. switch Thread (): ĠMaybe < T > Ġ= ĊĠĠĠĠĠĠĠ Ġcompose ( Rx Scheduler Transformer ()) Ċ Ċ fun ĠComp letable . switch Thread (): ĠComp letable Ġ= ĊĠĠĠĠĠĠĠ Ġcompose ( Rx Scheduler Transformer < Any >()) Ċ Ċ /** Ġ--------- Ġobserver On Ġextensions Ġ--------- Ġ**/ Ċ Ċ fun Ġ< T > ĠObservable < T >. observer On Ui (): ĠObservable < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠFlow able < T >. observer On Ui (): ĠFlow able < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠSingle < T >. observer On Ui (): ĠSingle < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠMaybe < T >. observer On Ui (): ĠMaybe < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun ĠComp letable . observer On Ui (): ĠComp letable Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠObservable < T >. observer On Io (): ĠObservable < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun Ġ< T > ĠFlow able < T >. observer On Io (): ĠFlow able < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun Ġ< T > ĠSingle < T >. observer On Io (): ĠSingle < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun Ġ< T > ĠMaybe < T >. observer On Io (): ĠMaybe < T > Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun ĠComp letable . observer On Io (): ĠComp letable Ġ= ĊĠĠĠĠĠĠĠ Ġobserve On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ /** Ġ--------- Ġsubscribe On Ġextensions Ġ--------- Ġ**/ Ċ Ċ fun Ġ< T > ĠObservable < T >. subscribe On Ui (): ĠObservable < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠFlow able < T >. subscribe On Ui (): ĠFlow able < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠSingle < T >. subscribe On Ui (): ĠSingle < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠMaybe < T >. subscribe On Ui (): ĠMaybe < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun ĠComp letable . subscribe On Ui (): ĠComp letable Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . ui ()) Ċ Ċ fun Ġ< T > ĠObservable < T >. subscribe On Io (): ĠObservable < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun Ġ< T > ĠFlow able < T >. subscribe On Io (): ĠFlow able < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun Ġ< T > ĠSingle < T >. subscribe On Io (): ĠSingle < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun Ġ< T > ĠMaybe < T >. subscribe On Io (): ĠMaybe < T > Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . io ()) Ċ Ċ fun ĠComp letable . subscribe On Io (): ĠComp letable Ġ= ĊĠĠĠĠĠĠĠ Ġsubscribe On ( Rx Scheduler Provider . INSTANCE . io ())