updateStreamSubscriptions method
Future<void>
updateStreamSubscriptions(
- int feedId,
- List<Stream>? added,
- List<Stream>? removed
)
Implementation
Future<void> updateStreamSubscriptions(
int feedId, List<Stream>? added, List<Stream>? removed) {
logTime(
'[updateStreamSubscriptions] subscriberHandleId: $_subscriberHandleId, publisherHandleId: $_publisherHandleId',
TAG);
_meetingId = _meetingId;
WsUpdateStreamSubscription requestPacket =
WsUpdateStreamSubscription(added: added, removed: removed);
requestPacket.messageType = Type.message;
requestPacket.handleId = _subscriberHandleId;
Completer completer = Completer();
_socketConnection.createCollectorAndSend(
requestPacket, Type.ack, completer);
return completer.future;
}