addStream 抽象方法

消费 stream 的元素。

监听 stream 并为每个事件做些处理。

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

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

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