package Ġcom . github . ced rick ring . react orm ong odb . collection . mono Ċ Ċ import Ġcom . github . ced rick ring . react orm ong odb . collection . Reactive Collection Ċ import Ġcom . mongodb . client . model . Update Options Ċ import Ġcom . mongodb . client . result . Update Result Ċ import Ġorg . bson . conversions . B son Ċ import Ġreactor . core . Core Subscriber Ċ import Ġreactor . core . publisher . Mono Ċ Ċ class ĠUpdate Mono < T >( private Ġval Ġreactive Collection : ĠReactive Collection < T >, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġfilter : ĠB son , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġupdate : ĠB son , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġupdate Options : ĠUpdate Options , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġmany : ĠBoolean Ġ= Ġfalse ) Ġ: ĠMono < Update Result >() Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġsubscribe ( actual : ĠCore Subscriber < in ĠUpdate Result > ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcallback : Ġ( update Result : ĠUpdate Result , Ġthrowable : ĠThrowable ?) Ġ-> ĠUnit Ġ= Ġ{ Ġupdate Result , Ġthrowable Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( throwable Ġ== Ġnull ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġactual ?. onNext ( update Result ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġactual ?. onError ( throwable ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġif Ġ( many ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactive Collection . native Collection . update Many ( filter , Ġupdate , Ġupdate Options , Ġcallback ) ĊĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreactive Collection . native Collection . update One ( filter , Ġupdate , Ġupdate Options , Ġcallback ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ Ċ }