Closes the input sink.
Future<void> close() async { _inputClosed = true; await _inputSink?.close(); }