Type Definition ConsumerMessageRx
omnistreams
type ConsumerMessageRx<T> = UnboundedReceiver<ConsumerMessage<T>>;