project reactor - Error Handling Asynchronous Events with a ConnectableFlux -

-

i have similar requirement author of post: handling errors in fluxsink continuously emits events.

i have implemented concatmap individually handle errors event handlers. however, have requirement have 2 operations occur asynchronously in parallel, before continuing next operation. therefore in code below, need modify handler2 , handler3 occur in parallel before proceeding handler4, instead of synchronously executing.

flux<objectfromqueue> flux = flux.create(fluxsink -> {      messagelistener.setfluxsink(fluxsink);      //messagelistener has 'process' method invoked there new message on queue. }, fluxsink.overflowstrategy.buffer);  connectableflux<objectfromqueue> connectableflux = flux.publish(); connectableflux     .concatmap(v -> mono.just(handler1.handle(v))             .doonerror(errorhandler::handle)             .onerrorresume(mono.empty())     .concatmap(v -> mono.just(handler2.handle(v))             .doonerror(errorhandler::handle)             .onerrorresume(mono.empty())     .concatmap(v -> mono.just(handler3.handle(v))             .doonerror(errorhandler::handle)             .onerrorresume(mono.empty())     .concatmap(v -> mono.just(handler4.handle(v))             .doonerror(errorhandler::handle)             .onerrorresume(mono.empty())     .subscribe() connectableflux.connect();

what best way configure connectableflux handle parallel, async events, while still ensuring error not terminate entire flux?

within concatmap function, tried create separate mono handler2 , handler3 , zip them make operations occur in parallel, not handling errors way want it. know of better approach making operations occur in parallel while still preventing errors terminating flux?


Comments

Post a Comment

Popular posts from this blog

ZeroMQ on Windows, with Qt Creator -

-
i have installed zmq link given below on windows 7. http://zeromq.org/distro:microsoft-windows 1) have c++ project in qt-creator , i'm using zmq c++ binding (zhelpers.hpp etc). 2) have added .lib installed zmq folder qtcreator 3) while compiling, compiler looks _imp__zmq_verion, in .dll files present in .lib have __imp_zmq_version. 4) causing undefined reference zmq_version. anyone else faced problem , has solution ?
Read more

unity3d - Unity SceneManager.LoadScene quits application -

-
i have 2 different scenes 1 named 'main' , other 'game' both added scenes in load. when use scenemanager.loadscene("game"); works no problem when tried return main scene code if (input.getkeydown (keycode.escape)) { scenemanager.loadscene("main"); } strangely game quits. thanks. sorry interruption. somewhere on other script found code. if (input.getkeydown (keycode.escape)) { application.quit (); } that's bad, know...
Read more

python - Error while using APScheduler: 'NoneType' object has no attribute 'now' -

-
i have python app hosting on heroku. use apscheduler call function every day @ time. strange thing 1 time function runs after while have following error log: exception in thread apscheduler (most raised during interpreter shutdown): 2017-09-06t15:03:28.347848+00:00 app[web.1]: traceback (most recent call last): 2017-09-06t15:03:28.347858+00:00 app[web.1]: file "/app/.heroku/python/lib/python2.7/threading.py", line 810, in __bootstrap_inner 2017-09-06t15:03:28.347859+00:00 app[web.1]: file "/app/.heroku/python/lib/python2.7/threading.py", line 763, in run 2017-09-06t15:03:28.347861+00:00 app[web.1]: file "/app/.heroku/python/lib/python2.7/site-packages/apscheduler/schedulers/blocking.py", line 27, in _main_loop 2017-09-06t15:03:28.348167+00:00 app[web.1]: <type 'exceptions.attributeerror'>: 'nonetype' object has no attribute 'now' any guesses? the full code long here key parts: def startdayauto(): global ...
Read more