stopReceiving method

Future<void> stopReceiving(
  1. int errorCode
)

Implementation

Future<void> stopReceiving(int errorCode) async {
  if (!_connected || _remoteWriteClosed) return;

  if (remoteId != null && _socket != null && !_socket!.closing) {
    _socket!.sendStreamPacket(
      remoteId!,
      id,
      [StopSendingFrame(streamId: remoteId!, errorCode: errorCode)],
      trackForRetransmit: false,
    );
  }

  _remoteWriteClosed = true;
  if (!_dataController.isClosed) {
    _dataController.close();
  }
  emit('end');

  if (_localWriteClosed) {
    await _close();
  }
}