package Ġcom . github . ced rick ring . react orm ong odb . collection . flux Ċ Ċ import Ġcom . github . ced rick ring . react orm ong odb . collection . Reactive Collection Ċ import Ġreactor . core . Core Subscriber Ċ import Ġreactor . core . publisher . Flux Ċ Ċ class ĠMap Reduce Flux < T , ĠResult >( private Ġval Ġreactive Collection : ĠReactive Collection < T >, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġmap Function : ĠString , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġreduce Function : ĠString , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġval Ġresult Class : ĠClass < Result >) Ġ: ĠFlux < Result >() Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġsubscribe ( actual : ĠCore Subscriber < in ĠResult > ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġreactive Collection . native Collection . map Reduce ( map Function , Ġreduce Function , Ġresult Class ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. forEach ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ{ Ġresult Ġ-> Ġactual ?. onNext ( result ) Ġ}, ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ{ Ġ_, Ġthrowable Ġ-> Ġif Ġ( throwable Ġ!= Ġnull ) Ġactual ?. onError ( throwable ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ Ċ } Ċ