wow-core/me.ahoo.wow.messaging.transport/TransportMessageBus/receiver

receiver

open override fun receiver(subscription: MessageSubscription): MessageReceiver<E>

The one receive entry: a single message source for subscription, with an explicit transport readiness boundary and processing admission (see MessageReceiver).

Cold transports whose subscription requires asynchronous initialization complete MessageReceiver.readiness only when new messages can no longer be missed. A runtime-owned subscription is a me.ahoo.wow.runtime.WowRuntime dispatcher's: local buses may let it take part in local-first delivery receipts.