Type Definition ProducerMessageTx
omnistreams
type ProducerMessageTx = UnboundedSender<ProducerMessage>;