package Ġcom . m ire go . tri kot . streams . reactive . processors Ċ Ċ import Ġcom . m ire go . tri kot . streams . c ancellable . C ancellable Manager Ċ import Ġcom . m ire go . tri kot . streams . tests . Mock Publisher Ċ import Ġcom . m ire go . tri kot . streams . reactive . Publish ers Ċ import Ġcom . m ire go . tri kot . streams . reactive . just Ċ import Ġcom . m ire go . tri kot . streams . reactive . onError Resume Next Ċ import Ġcom . m ire go . tri kot . streams . reactive . subscribe Ċ import Ġkotlin . test . Test Ċ import Ġkotlin . test . assertEquals Ċ import Ġkotlin . test . assertFalse Ċ import Ġkotlin . test . assertTrue Ċ Ċ class ĠOn Error Resume Next Processor Tests Ġ{ ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun ĠonError Resume Next _ with Next And Completion () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġpublisher Ġ= ĠPublish ers . behavior Subject < String >() ĊĠĠĠĠĠĠĠ Ġval Ġexpected Error Ġ= ĠException () ĊĠĠĠĠĠĠĠ Ġpublisher . error Ġ= Ġexpected Error ĊĠĠĠĠĠĠĠ Ġval Ġexpected Value Ġ= Ġ" EXPECTED _ VALUE " ĊĠĠĠĠĠĠĠ Ġvar Ġreceived Error : ĠThrowable ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġvar Ġreceived Value : ĠString ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġvar Ġis Completed Ġ= Ġfalse ĊĊĠĠĠĠĠĠĠ Ġpublisher . onError Resume Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreceived Error Ġ= Ġit ĊĠĠĠĠĠĠĠĠĠĠĠ Ġexpected Value . just () ĊĠĠĠĠĠĠĠ Ġ}. subscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠC ancellable Manager (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Next Ġ= Ġ{ Ġreceived Value Ġ= Ġit Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ ĠonError Ġ= Ġ{ Ġthrow ĠIllegalStateException (" Should Ġnot Ġreturn Ġan Ġerror ") Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Completed Ġ= Ġ{ Ġis Completed Ġ= Ġtrue Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ ĠassertEquals ( expected Error , Ġreceived Error ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( expected Value , Ġreceived Value ) ĊĠĠĠĠĠĠĠ ĠassertTrue ( is Completed , Ġ" Should Ġbe Ġcompleted ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun ĠonError Resume Next _ with Next And No Completion () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġpublisher Ġ= ĠPublish ers . behavior Subject < String >() ĊĠĠĠĠĠĠĠ Ġval Ġexpected Error Ġ= ĠException () ĊĠĠĠĠĠĠĠ Ġpublisher . error Ġ= Ġexpected Error ĊĠĠĠĠĠĠĠ Ġval Ġexpected Value Ġ= Ġ" EXPECTED _ VALUE " ĊĠĠĠĠĠĠĠ Ġvar Ġreceived Error : ĠThrowable ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġvar Ġreceived Value : ĠString ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġvar Ġis Completed Ġ= Ġfalse ĊĊĠĠĠĠĠĠĠ Ġpublisher . onError Resume Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreceived Error Ġ= Ġit ĊĠĠĠĠĠĠĠĠĠĠĠ ĠPublish ers . behavior Subject ( expected Value ) ĊĠĠĠĠĠĠĠ Ġ}. subscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠC ancellable Manager (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Next Ġ= Ġ{ Ġreceived Value Ġ= Ġit Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ ĠonError Ġ= Ġ{ Ġthrow ĠIllegalStateException (" Should Ġnot Ġreturn Ġan Ġerror ") Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Completed Ġ= Ġ{ Ġis Completed Ġ= Ġtrue Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ ĠassertEquals ( expected Error , Ġreceived Error ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( expected Value , Ġreceived Value ) ĊĠĠĠĠĠĠĠ ĠassertFalse ( is Completed , Ġ" Should Ġbe Ġnot Ġbe Ġcompleted ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun ĠonError Resume Next _ with Error () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġpublisher Ġ= ĠPublish ers . behavior Subject < String >() ĊĠĠĠĠĠĠĠ Ġval Ġexpected Error Ġ= ĠException () ĊĠĠĠĠĠĠĠ Ġpublisher . error Ġ= Ġexpected Error ĊĠĠĠĠĠĠĠ Ġval Ġresume Error Ġ= ĠException () ĊĠĠĠĠĠĠĠ Ġvar Ġreceived Error : ĠThrowable ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġvar Ġreceived Resume Error : ĠThrowable ? Ġ= Ġnull ĊĠĠĠĠĠĠĠ Ġvar Ġis Completed Ġ= Ġfalse ĊĊĠĠĠĠĠĠĠ Ġpublisher . onError Resume Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreceived Error Ġ= Ġit ĊĠĠĠĠĠĠĠĠĠĠĠ ĠPublish ers . error ( resume Error ) ĊĠĠĠĠĠĠĠ Ġ}. subscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠC ancellable Manager (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Next Ġ= Ġ{ Ġthrow ĠIllegalStateException (" Should Ġnot Ġreturn Ġa Ġvalue ") Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ ĠonError Ġ= Ġ{ Ġreceived Resume Error Ġ= Ġit Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Completed Ġ= Ġ{ Ġis Completed Ġ= Ġtrue Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ ĠassertEquals ( expected Error , Ġreceived Error ) ĊĠĠĠĠĠĠĠ ĠassertEquals ( resume Error , Ġreceived Resume Error ) ĊĠĠĠĠĠĠĠ ĠassertFalse ( is Completed , Ġ" Should Ġnot Ġbe Ġcompleted ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun ĠonError Resume Next _ with Empty () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġpublisher Ġ= ĠPublish ers . behavior Subject < String >() ĊĠĠĠĠĠĠĠ Ġval Ġexpected Error Ġ= ĠException () ĊĠĠĠĠĠĠĠ Ġpublisher . error Ġ= Ġexpected Error ĊĠĠĠĠĠĠĠ Ġvar Ġis Completed Ġ= Ġfalse ĊĊĠĠĠĠĠĠĠ Ġpublisher . onError Resume Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠPublish ers . empty () ĊĠĠĠĠĠĠĠ Ġ}. subscribe ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠC ancellable Manager (), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Next Ġ= Ġ{ Ġthrow ĠIllegalStateException (" Should Ġnot Ġreturn Ġa Ġvalue ") Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ ĠonError Ġ= Ġ{ Ġthrow ĠIllegalStateException (" Should Ġnot Ġreturn Ġan Ġerror ") Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠ Ġon Completed Ġ= Ġ{ Ġis Completed Ġ= Ġtrue Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ ĠassertTrue ( is Completed , Ġ" Should Ġbe Ġcompleted ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġparent Is Un subscribed OnError () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġparent Publisher Ġ= ĠMock Publisher (). also Ġ{ Ġit . error Ġ= ĠThrowable () Ġ} ĊĠĠĠĠĠĠĠ Ġparent Publisher . onError Resume Next Ġ{ Ġ" a ". just () Ġ}. subscribe ( C ancellable Manager ()) Ġ{ ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ ĠassertFalse ( parent Publisher . get Has Subscriptions ) ĊĠĠĠ Ġ} Ċ } Ċ