package Ġcom . ts are v . fi ot cher . internal Ċ Ċ import Ġcom . ts are v . fi ot cher . api . Sto pp able Ċ import Ġjava . util . concurrent . Executor Ċ import Ġjava . util . concurrent . Flow Ċ Ċ /** Ċ Ġ* ĠMarker Ġinterface , Ġthat Ġcan Ġchain Ġevent Ġprocessing Ġwithin Ġ[ Way Station ] Ġcontext . Ċ Ġ*/ Ċ interface ĠCh aining Listener < Resource T Ġ: ĠAny > Ġ: ĠFlow . Subscriber < Event With Exception < Resource T >>, ĠSto pp able Ġ{ ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠCreate Ġproxy Ġlistener , Ġthat Ġwill Ġhandle Ġsplit Ġevents Ġin Ġnew Ġqueue . ĊĠĠĠĠ Ġ* ĊĠĠĠĠ Ġ* Ġ@ transformer Ġa Ġfunction Ġthat Ġaccepts Ġ[ From T ] Ġevent Ġand Ġfunction Ġto Ġpublish Ġit Ġfurther , ĊĠĠĠĠ Ġ* Ġthus Ġallowing Ġto Ġmake Ġa Ġnumber Ġof Ġpublishing Ġon Ġits Ġdes ire . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġfun Ġ< From T Ġ: ĠAny > Ġasync Delegate From ( ĊĠĠĠĠĠĠĠ Ġexecutor : ĠExecutor , ĊĠĠĠĠĠĠĠ Ġmax Capacity : ĠInt , ĊĠĠĠĠĠĠĠ Ġtransformer : Ġ( From T , Ġ( Resource T ) Ġ-> ĠUnit ) Ġ-> ĠUnit , ĊĠĠĠĠĠĠĠ Ġhandle Errors : Ġ(( Throwable ) Ġ-> ĠThrowable ? )? , ĊĠĠĠ Ġ): ĠCh aining Listener < From T > Ċ Ċ }