@override Future<void> close() async { if (_closed) return; _closed = true; await _queue; await _handle.close(); }