@override Future<void> close() async { _queryChunks.clear(); _controller?.close(); _controller = null; onClose(); }