Type Definition ProducerMessageRx
omnistreams
type ProducerMessageRx = UnboundedReceiver<ProducerMessage>;