subscribeChannel method

Stream subscribeChannel(
  1. String channel
)

Implementation

Stream<dynamic> subscribeChannel(String channel) {
  StreamController streamController = StreamController<dynamic>();

  streamController.onCancel = () {
    unregisterHandler(channel, streamController);
  };
  registerHandler(channel, streamController);

  send(channel, type: RealtimeMessageTypes.realtimeMessageTypeSubscribe);

  return streamController.stream;
}