updateStreamSubscriptions method

Future<void> updateStreamSubscriptions(
  1. int feedId,
  2. List<Stream>? added,
  3. 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;
}