完成 属性

Future 完成

返回一个当 StreamSink 完成时完成的 future。

如果 StreamSink 因为错误而失败,可能是通过使用 addaddErrorclose 添加事件时发生的,则 done future 将以该错误完成。

否则,返回的 future 将在以下任一情况下完成:

  • 所有事件都已被处理并且 sink 已关闭,或者
  • sink 已经停止处理更多事件(例如通过取消流订阅)。

实现

Future get done;