addStream 抽象方法

消费 stream 的元素。

监听 stream 并对每个事件执行某些操作。

返回一个 Future，当流添加完成且消费者准备好接受新的流时完成。在返回的 Future 完成之前不应发生对 addStream 或 close 的进一步调用。

消费者可能在出现错误后停止监听流，它可能消费所有错误并在完成事件时停止，或者如果接收者不想接收更多事件，它可能提前取消。

如果消费者因为某些阻止其继续的错误而停止监听，它可能在返回的 Future 中报告此错误，否则它将以 null 完成Future。