listen 方法

StreamSubscription<RawSecureSocket> listen(
  1. void onData(
    1. RawSecureSocket s
    )?, {
  2. Function? onError,
  3. void onDone()?,
  4. bool? cancelOnError,
})
override

向此流添加订阅。

返回一个 StreamSubscription，该订阅使用提供的 onData、onError 和 onDone 处理器处理此流的事件。处理器可以在订阅中更改，但它们最初是提供的函数。

对于此流中的每个数据事件，都会调用订阅者的 onData 处理器。如果 onData 为 null，则不执行任何操作。

对于此流中的错误，会调用 onError 处理器，并带有错误对象和可能的堆栈跟踪。

onError 回调必须是类型 void Function(Object error) 或 void Function(Object error, StackTrace)。函数类型决定了是否使用堆栈跟踪参数调用 onError。堆栈跟踪参数可能是 StackTrace.empty，如果此流收到没有堆栈跟踪的错误。

否则，它只带有错误对象。如果省略 onError，则此流上的任何错误都视为未处理，并将传递给当前 Zone 的错误处理器。默认情况下，未处理的异步错误被视为未捕获的顶层错误。

如果此流关闭并发出完成事件，则调用 onDone 处理器。如果 onDone 为 null，则不执行任何操作。

如果 cancelOnError 为 true，则在首次错误事件传递时自动取消订阅。默认为 false。

当订阅暂停或已被取消时，订阅不会接收事件，并且不会调用任何事件处理函数。

实现

StreamSubscription<RawSecureSocket> listen(void onData(RawSecureSocket s)?,
    {Function? onError, void onDone()?, bool? cancelOnError}) {
  return _controller.stream.listen(onData,
      onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}