Stops reading.
@override Future<void> close() async { _closed = true; final wake = _wake; if (wake != null && !wake.isCompleted) { wake.complete(); } }