courierMessageStream<T> abstract method

Stream<T> courierMessageStream<T>(
  1. String topic, {
  2. MessageAdapter adapter,
  3. dynamic decoder,
})

Implementation

Stream<T> courierMessageStream<T>(String topic,
    {MessageAdapter adapter, dynamic decoder});