bindInbound method

void bindInbound(
  1. Stream<String> messages
)

Binds an inbound JSON stream to this channel.

Implementation

void bindInbound(Stream<String> messages) {
  _inboundSubscription?.cancel();
  _inboundSubscription = messages.listen(addInboundJson);
}