anchor.diff:            break;
         }
       } else if (payload is EnsureOpen) {
  -      return _handleEnsureOpen(payload);
  +      return _handleEnsureOpen(comms, payload);
       } else if (payload is ExecuteQuery) {
         final token = runCancellable(() => _runQuery(
             payload.method, payload.sql, payload.args, payload.executorId));
  
positive.code: 
    final Map<int, QueryExecutor> _managedExecutors = {};
    int _currentExecutorId = 0;
  
    final Map<int, CancellationToken> _cancellableOperations = {};
  
  
negative.code:   final StreamController<void> _backlogUpdated =
        StreamController.broadcast(sync: true);
  
    bool _isShuttingDown = false;
    final Set<DriftCommunication> _activeChannels = {};
    final Completer<void> _done = Completer();
  