Type Definition omnistreams::ConsumerMessageTx

type ConsumerMessageTx<T> = UnboundedSender<ConsumerMessage<T>>;