package Ġarrow . fx . reactor . extensions . flux k . mon ad Error Ċ Ċ import Ġarrow . Kind Ċ import Ġarrow . core . Either Ċ import Ġarrow . fx . reactor . De prec ate Reactor Ċ import Ġarrow . fx . reactor . Flux K Ċ import Ġarrow . fx . reactor . Flux K . Companion Ċ import Ġarrow . fx . reactor . For Flux K Ċ import Ġarrow . fx . reactor . extensions . Flux K Monad Error Ċ import Ġkotlin . Boolean Ċ import Ġkotlin . Deprecated Ċ import Ġkotlin . Function 0 Ċ import Ġkotlin . Function 1 Ċ import Ġkotlin . Published Api Ċ import Ġkotlin . Suppress Ċ import Ġkotlin . Throwable Ċ import Ġkotlin . jvm . Jvm Name Ċ Ċ /** Ċ Ġ* Ġcached Ġextension Ċ Ġ*/ Ċ @ Published Api () Ċ internal Ġval Ġmon ad Error _ singleton : ĠFlux K Monad Error Ġ= Ġobject Ġ: ĊĠ Ġarrow . fx . reactor . extensions . Flux K Monad Error Ġ{} Ċ Ċ @ Jvm Name (" ensure ") Ċ @ Suppress ( ĊĠ Ġ" UN CHECK ED _ CAST ", ĊĠ Ġ" USE LESS _ CAST ", ĊĠ Ġ" EXTENSION _ SH ADOW ED _ BY _ MEMBER ", ĊĠ Ġ" UNUSED _ PARAMETER " Ċ ) Ċ @ Deprecated ( De prec ate Reactor ) Ċ fun Ġ< A > ĠKind < For Flux K , ĠA >. ensure ( arg 1 : ĠFunction 0 < Throwable >, Ġarg 2 : ĠFunction 1 < A , ĠBoolean >): ĠFlux K < A > Ġ= ĊĠ Ġarrow . fx . reactor . Flux K . mon ad Error (). run Ġ{ ĊĠĠĠ Ġthis @ ensure . ensure < A >( arg 1 , Ġarg 2 ) Ġas Ġarrow . fx . reactor . Flux K < A > ĊĠ Ġ} Ċ Ċ @ Jvm Name (" re deem With ") Ċ @ Suppress ( ĊĠ Ġ" UN CHECK ED _ CAST ", ĊĠ Ġ" USE LESS _ CAST ", ĊĠ Ġ" EXTENSION _ SH ADOW ED _ BY _ MEMBER ", ĊĠ Ġ" UNUSED _ PARAMETER " Ċ ) Ċ @ Deprecated ( De prec ate Reactor ) Ċ fun Ġ< A , ĠB > ĠKind < For Flux K , ĠA >. re deem With ( ĊĠ Ġarg 1 : ĠFunction 1 < Throwable , ĠKind < For Flux K , ĠB >>, ĊĠ Ġarg 2 : ĠFunction 1 < A , ĠKind < For Flux K , ĠB >> Ċ ): ĠFlux K < B > Ġ= Ġarrow . fx . reactor . Flux K . mon ad Error (). run Ġ{ ĊĠ Ġthis @ re deem With . re deem With < A , ĠB >( arg 1 , Ġarg 2 ) Ġas Ġarrow . fx . reactor . Flux K < B > Ċ } Ċ Ċ @ Jvm Name (" re throw ") Ċ @ Suppress ( ĊĠ Ġ" UN CHECK ED _ CAST ", ĊĠ Ġ" USE LESS _ CAST ", ĊĠ Ġ" EXTENSION _ SH ADOW ED _ BY _ MEMBER ", ĊĠ Ġ" UNUSED _ PARAMETER " Ċ ) Ċ @ Deprecated ( De prec ate Reactor ) Ċ fun Ġ< A > ĠKind < For Flux K , ĠEither < Throwable , ĠA >> . re throw (): ĠFlux K < A > Ġ= ĊĠ Ġarrow . fx . reactor . Flux K . mon ad Error (). run Ġ{ ĊĠĠĠ Ġthis @ re throw . re throw < A >() Ġas Ġarrow . fx . reactor . Flux K < A > ĊĠ Ġ} Ċ Ċ @ Suppress ( ĊĠ Ġ" UN CHECK ED _ CAST ", ĊĠ Ġ" NOTH ING _ TO _ INLINE " Ċ ) Ċ @ Deprecated ( De prec ate Reactor ) Ċ inline Ġfun ĠComp anion . mon ad Error (): ĠFlux K Monad Error Ġ= Ġmon ad Error _ singleton Ċ