streamChannelMessagesSubscribe method

void streamChannelMessagesSubscribe(
  1. WebSocketChannel webSocketChannel,
  2. Channel channel
)

Implementation

void streamChannelMessagesSubscribe(
    WebSocketChannel webSocketChannel, Channel channel) {
  Map msg = {
    "msg": "sub",
    "id": channel.id! + "subscription-id",
    "name": "stream-room-messages",
    "params": [channel.id, false]
  };
  webSocketChannel.sink.add(jsonEncode(msg));
}