package Ġme . s aket . press . shared . sync er Ċ Ċ import Ġco . touch lab . state ly . concurrency . Atomic Int Ċ import Ġcom . bad oo . reak t ive . comp letable . Comp letable Ċ import Ġcom . bad oo . reak t ive . observable . first Or Error Ċ import Ġcom . bad oo . reak t ive . observable . observable Of Never Ċ import Ġcom . bad oo . reak t ive . single . as Comp letable Ċ import Ġcom . bad oo . reak t ive . subject . behavior . Behavior Subject Ċ import Ġcom . bad oo . reak t ive . subject . publish . Publish Subject Ċ import Ġme . s aket . press . shared . sync er . Sync er . Status . Disabled Ċ import Ġme . s aket . press . shared . sync er . git . File Ċ Ċ class ĠFake Sync er Ġ: ĠSync er () Ġ{ ĊĠ Ġprivate Ġvar Ġsync Ġ= ĠPublish Subject < Unit >() ĊĠ Ġvar Ġsync Request Count Ġ= ĠAtomic Int ( 0 ) ĊĠ Ġval Ġstatus Ġ= ĠBehavior Subject < Status >( Disabled ) ĊĊĠ Ġoverride Ġfun Ġsync Comp letable (): ĠComp letable Ġ{ ĊĠĠĠ Ġsync Request Count . increment AndGet () ĊĠĠĠ Ġreturn Ġsync . first Or Error (). as Comp letable () ĊĠ Ġ} ĊĊĠ Ġfun Ġfinish Sync () Ġ= Ġsync . onNext ( Unit ) ĊĊĠ Ġoverride Ġfun Ġstatus () Ġ= Ġstatus ĊĊĠ Ġoverride Ġval Ġdirectory : ĠFile Ġget () Ġ= ĠTODO () ĊĠ Ġoverride Ġfun Ġsync () Ġ= Ġerror (" sync Comp letable () Ġshould Ġbe Ġused ") ĊĠ Ġoverride Ġfun Ġdisable () Ġ= ĠUnit Ċ } Ċ