package Ġcom . el pass ion . android . commons . rx java Ċ Ċ import Ġorg . junit . Test Ċ import Ġrx . ob servers . Test Subscriber Ċ import Ġrx . subjects . Publish Subject Ċ Ċ class ĠChanges Test Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġsubject Ġ= ĠPublish Subject . create < Int >() ĊĠĠĠ Ġprivate Ġval Ġsubscriber Ġ= ĠTest Subscriber < Pair < Int , ĠInt >>() ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Return Correct Pair () Ġ{ ĊĊĠĠĠĠĠĠĠ Ġsubject ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. changes ( 0 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 1 ) ĊĊĠĠĠĠĠĠĠ Ġsubscriber . assert Values ( 0 Ġto Ġ 1 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġshould Return Correct Pairs () Ġ{ ĊĊĠĠĠĠĠĠĠ Ġsubject ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. changes ( 0 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 1 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 2 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 3 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 4 ) ĊĊĠĠĠĠĠĠĠ Ġsubscriber . assert Values ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 0 Ġto Ġ 1 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 1 Ġto Ġ 2 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 2 Ġto Ġ 3 , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ 3 Ġto Ġ 4 ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test Ġ// Ġnot Ġactually Ġneeded Ġbut Ġfun Ġ:) ĊĠĠĠ Ġfun Ġshould Return Correct Pairs Of Pairs () Ġ{ ĊĊĠĠĠĠĠĠĠ Ġval Ġsubscriber Ġ= ĠTest Subscriber < Pair < Pair < Int , ĠInt >, ĠPair < Int , ĠInt >> >() ĊĊĠĠĠĠĠĠĠ Ġsubject ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. changes ( 3 3 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. changes ( 6 6 6 Ġto Ġ 6 6 7 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ( subscriber ) ĊĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 9 9 9 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 9 9 8 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 9 9 7 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 9 9 6 ) ĊĊĠĠĠĠĠĠĠ Ġsubscriber . assert Values ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ( 6 6 6 Ġto Ġ 6 6 7 ) Ġto Ġ( 3 3 3 Ġto Ġ 9 9 9 ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ( 3 3 3 Ġto Ġ 9 9 9 ) Ġto Ġ( 9 9 9 Ġto Ġ 9 9 8 ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ( 9 9 9 Ġto Ġ 9 9 8 ) Ġto Ġ( 9 9 8 Ġto Ġ 9 9 7 ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ( 9 9 8 Ġto Ġ 9 9 7 ) Ġto Ġ( 9 9 7 Ġto Ġ 9 9 6 ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ }