subscribe method

Future<void> subscribe(
  1. Set<int> feeds
)

Implementation

Future<void> subscribe(Set<int> feeds) {
  WsRoomPacket requestPacket = WsRoomPacket();
  requestPacket.messageType = Type.message;
  requestPacket.handleId = _subscriberHandleId;
  requestPacket.body = Body()
    ..room = _meetingId
    ..request = WsRoomPacketType.subscribe
    ..feeds = Map.fromEntries(feeds.map((userId) {
      return MapEntry(userId, activePublisherStreams[userId]);
    }))
    ..userId = _currentUserId;
  Completer completer = Completer();
  _socketConnection.createCollectorAndSend(
      requestPacket, Type.ack, completer);
  return completer.future;
}