package Ġcom . bad oo . reak t ive . maybe Ċ Ċ import Ġcom . bad oo . reak t ive . base . Source Tests Ċ import Ġcom . bad oo . reak t ive . base . Source Tests Impl Ċ import Ġcom . bad oo . reak t ive . comp letable . Comp letable Ċ import Ġcom . bad oo . reak t ive . test . base . assert Disposed Ċ import Ġcom . bad oo . reak t ive . test . comp letable . assert Complete Ċ import Ġcom . bad oo . reak t ive . test . comp letable . test Ċ import Ġcom . bad oo . reak t ive . test . maybe . Test Maybe Ċ import Ġkotlin . test . Ignore Ċ import Ġkotlin . test . Test Ċ Ċ interface ĠMaybe To Comp letable Tests Ġ: ĠSource Tests Ġ{ ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġcompletes _ WHEN _ upstream _ is _ completed () ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġdis poses _ down stream _ dis posable _ WHEN _ upstream _ completed () ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġdis poses _ down stream _ dis posable _ WHEN _ upstream _ succeeded () Ċ } Ċ Ċ @ Ignore Ċ class ĠMaybe To Comp letable Tests Impl ( ĊĠĠĠ Ġtransform : ĠMaybe < Unit >. () Ġ-> ĠComp letable Ċ ) Ġ: ĠMaybe To Comp letable Tests , ĠSource Tests Ġby ĠSource Tests Impl ( Test Maybe < Nothing >(), Ġ{ Ġtransform (). test () Ġ}) Ġ{ ĊĊĠĠĠ Ġ@ Deprecated (" Just Ġto Ġfix Ġcompl ilation Ġissues ") ĊĠĠĠ Ġconstructor () Ġ: Ġthis ({ Ġthrow ĠUnsupportedOperationException () Ġ}) ĊĊĠĠĠ Ġprivate Ġval Ġupstream Ġ= ĠTest Maybe < Unit >() ĊĠĠĠ Ġprivate Ġval Ġobserver Ġ= Ġupstream . transform (). test () ĊĊĠĠĠ Ġoverride Ġfun Ġcompletes _ WHEN _ upstream _ is _ completed () Ġ{ ĊĠĠĠĠĠĠĠ Ġupstream . onComplete () ĊĊĠĠĠĠĠĠĠ Ġobserver . assert Complete () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġdis poses _ down stream _ dis posable _ WHEN _ upstream _ completed () Ġ{ ĊĠĠĠĠĠĠĠ Ġupstream . onComplete () ĊĊĠĠĠĠĠĠĠ Ġobserver . assert Disposed () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġdis poses _ down stream _ dis posable _ WHEN _ upstream _ succeeded () Ġ{ ĊĠĠĠĠĠĠĠ Ġupstream . on Success ( Unit ) ĊĊĠĠĠĠĠĠĠ Ġobserver . assert Disposed () ĊĠĠĠ Ġ} Ċ } Ċ