package Ġfunc ify . feature . tools . container . deferred . template Ċ Ċ import Ġfunc ify . feature . tools . container . async . K Future Ċ import Ġfunc ify . feature . tools . container . deferred . container . Deferred Container Ċ import Ġfunc ify . feature . tools . container . deferred . container . Deferred Container Factory Ċ import Ġfunc ify . feature . tools . container . deferred . container . Deferred Container Factory . K Future Deferred Container . Companion . K Future Deferred Container WT Ċ import Ġfunc ify . feature . tools . container . deferred . container . Deferred Container Factory . narrow ed Ċ import Ġfunc ify . feature . tools . extensions . String Extensions . flatten Into One Line Ċ import Ġjava . util . concurrent . Completion Stage Ċ import Ġjava . util . concurrent . Executor Ċ import Ġreactor . core . publisher . Flux Ċ import Ġreactor . core . publisher . Mono Ċ import Ġreactor . core . scheduler . Scheduler Ċ Ċ internal Ġinterface ĠExec Context K Future Deferred Template Ġ: ĊĠĠĠ ĠExecutionContext Deferred Template < K Future Deferred Container WT >, ĠK Future Deferred Template Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġmap ( ĊĠĠĠĠĠĠĠ Ġexecutor : ĠExecutor , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠO , ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer . narrow ed (). k Future . map ( executor , Ġmapper ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map K Future ( ĊĠĠĠĠĠĠĠ Ġexecutor : ĠExecutor , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠK Future < O >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer . narrow ed (). k Future . flatMap ( executor , Ġmapper ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map Completion Stage ( ĊĠĠĠĠĠĠĠ Ġexecutor : ĠExecutor , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠCompletion Stage < out ĠO >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer . narrow ed (). k Future . flatMap Completion Stage ( executor , Ġmapper ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map Mono ( ĊĠĠĠĠĠĠĠ Ġexecutor : ĠExecutor , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠMono < out ĠO >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer . narrow ed (). k Future . flatMap Completion Stage ( executor ) Ġ{ Ġi : ĠI Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmapper . invoke ( i ). to Future () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map Flux ( ĊĠĠĠĠĠĠĠ Ġexecutor : ĠExecutor , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠFlux < out ĠO >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġthrow ĠUnsupportedOperationException ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ""" use Ġof Ġthis Ġmethod Ġ[ Ġname : Ġflat Map Flux Ġ] Ġon Ġa ĠĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ| K Future Ġcontainer Ġwould Ġpotentially Ġresult Ġin ĠĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ| a Ġloss Ġof Ġinformation Ġand Ġso Ġis Ġnot Ġsupported """. flatten Into One Line () ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġmap ( ĊĠĠĠĠĠĠĠ Ġscheduler : ĠScheduler , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠO , ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer . narrow ed (). k Future . map ( Executor Ġ{ Ġr Ġ-> Ġscheduler . schedule ( r ) Ġ}, Ġmapper ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map K Future ( ĊĠĠĠĠĠĠĠ Ġscheduler : ĠScheduler , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠK Future < O >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. narrow ed () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. k Future ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. flatMap ( executor Ġ= ĠExecutor Ġ{ Ġr Ġ-> Ġscheduler . schedule ( r ) Ġ}, Ġmapper Ġ= Ġmapper ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map Completion Stage ( ĊĠĠĠĠĠĠĠ Ġscheduler : ĠScheduler , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠCompletion Stage < out ĠO >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. narrow ed () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. k Future ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. flatMap Completion Stage ( Executor Ġ{ Ġr Ġ-> Ġscheduler . schedule ( r ) Ġ}, Ġmapper ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map Mono ( ĊĠĠĠĠĠĠĠ Ġscheduler : ĠScheduler , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠMono < out ĠO >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠDeferred Container Factory . K Future Deferred Container ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontainer . narrow ed (). k Future . flatMap Completion Stage ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠExecutor Ġ{ Ġr Ġ-> Ġscheduler . schedule ( r ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) Ġ{ Ġi : ĠI Ġ-> Ġmapper . invoke ( i ). to Future () Ġ} ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġ< I , ĠO > Ġflat Map Flux ( ĊĠĠĠĠĠĠĠ Ġscheduler : ĠScheduler , ĊĠĠĠĠĠĠĠ Ġmapper : Ġ( I ) Ġ-> ĠFlux < out ĠO >, ĊĠĠĠĠĠĠĠ Ġcontainer : ĠDeferred Container < K Future Deferred Container WT , ĠI > ĊĠĠĠ Ġ): ĠDeferred Container < K Future Deferred Container WT , ĠO > Ġ{ ĊĠĠĠĠĠĠĠ Ġthrow ĠUnsupportedOperationException ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ""" use Ġof Ġthis Ġmethod Ġ[ Ġname : Ġflat Map Flux Ġ] Ġon Ġa ĠĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ| K Future Ġcontainer Ġwould Ġpotentially Ġresult Ġin ĠĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ| a Ġloss Ġof Ġinformation Ġand Ġso Ġis Ġnot Ġsupported """. flatten Into One Line () ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ } Ċ