package Ġru . f om enk ov . rx dis posable watcher Ċ Ċ import Ġio . reactivex . rx java 3 . core . Back pressure Strategy Ċ import Ġio . reactivex . rx java 3 . core . Observable Ċ import Ġorg . junit . Assert . assertEquals Ċ import Ġorg . junit . Test Ċ Ċ class ĠFlow able Test Ġ: ĠBaseTest () Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġobservable Ġ= ĠObservable . create < Int > Ġ{} ĊĠĠĠ Ġprivate Ġval Ġflow able Ġ= Ġobservable . to Flow able ( Back pressure Strategy . LATE ST ) ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest () Ġ{ ĊĠĠĠĠĠĠĠ Ġval ĠclassName Ġ= Ġjava Class . name ĊĠĠĠĠĠĠĠ Ġval ĠmethodName Ġ= Ġ" test " ĊĊĠĠĠĠĠĠĠ Ġflow able . subscribe () ĊĠĠĠĠĠĠĠ Ġfor Ġ( i Ġin Ġ 0 Ġ.. Ġ 1 ) Ġ{ Ġflow able . subscribe () Ġ} ĊĠĠĠĠĠĠĠ Ġfor Ġ( i Ġin Ġ 0 Ġ.. Ġ 2 ) Ġ{ Ġflow able . subscribe () Ġ} ĊĠĠĠĠĠĠĠ Ġflow able . subscribe (). dispose () Ġ// ĠDis posed ĊĠĠĠĠĠĠĠ Ġfor Ġ( i Ġin Ġ 0 Ġ.. Ġ 1 0 ) Ġ{ Ġflow able . subscribe (). dispose () Ġ} Ġ// ĠDis posed ĊĊĠĠĠĠĠĠĠ Ġval Ġresult Ġ= ĠRx Disposable Watcher . probe (). sortBy First Element LineNumber () ĊĠĠĠĠĠĠĠ ĠassertEquals ( 3 , Ġresult . size ) ĊĠĠĠĠĠĠĠ Ġresult [ 0 ]. assert Probe Entry ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Entries Ġ= Ġ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Source Type Ġ= ĠSource Type . FLOW ABLE , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected ClassName Ġ= ĠclassName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Method Ġ= ĠmethodName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected LineNumber Ġ= Ġ 1 8 ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġresult [ 1 ]. assert Probe Entry ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Entries Ġ= Ġ 2 , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Source Type Ġ= ĠSource Type . FLOW ABLE , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected ClassName Ġ= ĠclassName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Method Ġ= ĠmethodName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected LineNumber Ġ= Ġ 1 9 ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġresult [ 2 ]. assert Probe Entry ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Entries Ġ= Ġ 3 , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Source Type Ġ= ĠSource Type . FLOW ABLE , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected ClassName Ġ= ĠclassName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Method Ġ= ĠmethodName , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected LineNumber Ġ= Ġ 2 0 ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ }