[][src]Type Definition omnistreams::ConsumerMessageRx

type ConsumerMessageRx<T> = UnboundedReceiver<ConsumerMessage<T>>;