Close the stream. After that, calls to add are no longer allowed.
@override Future<void> close() { _fromStreamSubscription?.cancel(); _fromStreamSubscription = null; return super.close(); }