@Mlmikael Subscribers contain a queue of handlers. These are closures over arbitrary state. An arbitrary closer must eventually be executed under all scenarios. Stop of the subscriber prevents new subscription so that a subsequent event can drain the handler queue with encountering a subscription race.