subscribe method
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;
}