@override Future<Result<int>> executeAsyncStart(String connectionId, String sql) => _stream.executeAsyncStart(connectionId, sql);