Is there any solution like following one for RxJS?Is it possible to invoke subscriberss OnNexts on dif