cancel method

  1. @override
Future<void> cancel([
  1. int errorCode = 0
])
override

Cancels the stream, telling the peer to stop sending.

Implementation

@override
Future<void> cancel([int errorCode = 0]) async {
  _cancelled = true;
  checkStatus(
    b.wt_recv_stream_stop(_handle, errorCode),
    'wt_recv_stream_stop',
  );
  final controller = _controller;
  if (controller != null && !controller.isClosed) await controller.close();
}