package Ġcom . id ap group . rx . sample Ċ Ċ import Ġandroid . annotation . Suppress Lint Ċ import Ġandroid . os . Bundle Ċ import Ġandroid . util . Log Ċ import Ġandroidx . appcompat . app . AppCompatActivity Ċ import Ġcom . id ap group . rx . k tx . debug Ċ import Ġcom . id ap group . rx . k tx . dispose On Stop Ċ import Ġio . reactivex . subjects . Behavior Subject Ċ import Ġkotlinx . android . synt hetic . main . activity _ main .* Ċ import Ġtim ber . log . Tim ber Ċ Ċ @ Suppress Lint (" SetText I 1 8 n ") Ċ class ĠMainActivity Ġ: ĠAppCompatActivity () Ġ{ ĊĊĠĠĠ Ġprivate Ġvar Ġwith Error Ġ= Ġfalse ĊĊĠĠĠ Ġoverride Ġfun ĠonCreate ( savedInstanceState : ĠBundle ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . onCreate ( savedInstanceState ) ĊĠĠĠĠĠĠĠ ĠsetContentView ( R . layout . activity _ main ) ĊĊĠĠĠĠĠĠĠ ĠTim ber . plant ( Tim ber . Debug Tree ()) ĊĊĠĠĠĠĠĠĠ ĠTim ber . plant ( object Ġ: ĠTim ber . Tree () Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġd ( t : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog ( Log . DEBUG , Ġnull Ġas ĠString ?, Ġ"", Ġt ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġd ( message : ĠString , Ġvar arg Ġargs : ĠAny ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog ( Log . DEBUG , Ġnull Ġas ĠString ?, Ġformat Message ( message , Ġargs ), Ġnull ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġd ( t : ĠThrowable , Ġmessage : ĠString , Ġvar arg Ġargs : ĠAny ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog ( Log . DEBUG , Ġnull Ġas ĠString ?, Ġformat Message ( message , Ġargs ), Ġt ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġlog ( priority : ĠInt , Ġtag : ĠString ?, Ġmessage : ĠString , Ġt : ĠThrowable ?) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġerror Text Ġ= Ġt ?. let Ġ{ Ġ", Ġerror : Ġ$ it " Ġ} Ġ?: Ġ"" ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġline Ġ= Ġ"${ tag . or Empty ()}. $ message $ error Text " ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġlog View . text Ġ= Ġ"${ log View . text }\ n ->$ line " ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠonStart () Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . onStart () ĊĠĠĠĠĠĠĠ Ġstart Work () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġstart Work () Ġ{ ĊĠĠĠĠĠĠĠ ĠTim ber . d (" ------------------------------------------------ ----- ") ĊĊĠĠĠĠĠĠĠ Ġval Ġsubject Ġ= ĠBehavior Subject . create Default ( 1 ) ĊĠĠĠĠĠĠĠ Ġsubject . debug (" My Tag ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe ({}, Ġ{}) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. dispose On Stop ( this ) ĊĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 5 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 6 7 0 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext ( 4 5 ) ĊĠĠĠĠĠĠĠ Ġsubject . onNext (- 3 9 ) ĊĠĠĠĠĠĠĠ Ġif Ġ( with Error ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġsubject . onError ( Exception ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġwith Error Ġ= Ġ! with Error Ċ // ĊĊĠĠĠ Ġ} Ċ } Ċ