package Ġcom . ruby licht en stein . rx test . matchers Ċ Ċ import Ġcom . ruby licht en stein . rx test . assertions . should Ċ import Ġcom . ruby licht en stein . rx test . assertions . should Emit Ċ import Ġcom . ruby licht en stein . rx test . assertions . should Have Ċ import Ġcom . ruby licht en stein . rx test . extent ions . test Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . ob servers . Base Test Consumer Ċ import Ġio . reactivex . ob servers . Test Observer Ċ import Ġorg . hamcrest . Core Matchers . notNull Value Ċ import Ġorg . hamcrest . Matcher Assert . assertThat Ċ import Ġorg . junit . Test Ċ import Ġorg . junit . runner . RunWith Ċ import Ġorg . junit . runners . JUnit 4 Ċ Ċ @ RunWith ( JUnit 4 :: class ) Ċ class ĠCreate Matcher Test Ġ{ ĊĊĊĠĠĠ Ġfun Ġ< T , ĠU Ġ: ĠBaseTest Consumer < T , ĠU >> Ġno Values () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ= Ġvalue Count < T , ĠU >( 0 ) ĊĊĠĠĠ Ġfun Ġ< T , ĠU Ġ: ĠBaseTest Consumer < T , ĠU >> Ġerror Or Complete ( error : ĠThrowable ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ= Ġerror < T , ĠU >( error ) Ġor Ġcomplete () ĊĊĠĠĠ Ġfun Ġ< T , ĠU Ġ: ĠBaseTest Consumer < T , ĠU >> Ġmore Values Then ( count : ĠInt ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ= Ġcreate Matcher < T , ĠU >({ Ġit . values (). size Ġ> Ġcount Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfail Message Ġ= Ġ" Less Ġvalues Ġthen Ġ$ count " ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġfun Ġ< T , ĠU Ġ: ĠBaseTest Consumer < T , ĠU >> Ġless Values Then ( count : ĠInt ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ= Ġcreate Matcher < T , ĠU >({ Ġit . values (). size Ġ< Ġcount Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfail Message Ġ= Ġ" More Ġvalues Ġthen Ġ$ count " ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġfun Ġ< T , ĠU Ġ: ĠBaseTest Consumer < T , ĠU >> Ġvalue Count Between ( min : ĠInt , Ġmax : ĠInt ) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmore Values Then < T , ĠU >( min ) Ġand Ġless Values Then < T , ĠU >( max ) ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġcreate Matcher Or And Test () Ġ{ ĊĠĠĠĠĠĠĠ ĠObservable . just ("", Ġ"") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġ( value Count Between < String , ĠTest Observer < String >>( 0 , Ġ 1 ) Ġor Ġvalues ("", Ġ"")) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġ( value Count Between < String , ĠTest Observer < String >>( 1 , Ġ 3 ) Ġand Ġvalues ("", Ġ"")) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġ( value Count Between < String , ĠTest Observer < String >>( 0 , Ġ 1 ) Ġand Ġvalues ("", Ġ"")) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠAssertionError ) Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġ( value Count Between < String , ĠTest Observer < String >>( 0 , Ġ 3 ) Ġor Ġvalues ("", Ġ"")) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġcreate Matcher Test () Ġ{ ĊĊĠĠĠĠĠĠĠ Ġval Ġvalues Ġ= ĠlistOf < String >(" Rx ", Ġ" Kotlin ", Ġ" Test ") ĊĠĠĠĠĠĠĠ ĠObservable . from Iterable ( values ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Emit Ġmore Values Then ( 2 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġno Errors () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġvalue Sequence ( values ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ ĠObservable . empty < String >() ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġno Values () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ ĠObservable . just ("") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġerror Or Complete ( Throwable ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ ĠObservable . just ("", Ġ"") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġvalue Count Between ( 1 , Ġ 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġcreate Fail Test () Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠObservable . just ("", Ġ"") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Have Ġmore Values Then ( 4 5 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( e , Ġnot NullValue ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġfail Test () Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠObservable . just ("") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. test Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit Ġshould Ġnot Complete () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( e , Ġnot NullValue ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } ĊĊ