code: @Override
      public void closeAll(final Queue queue) {
  
          closed.set(true);
          if (queue != null) {
              queue.closeAndClear();
              queuesToLeft(queue).forEach(Queue::closeAndClear);
          }
  
      }
docs: /* (non-Javadoc)
  @see Continueable#closeAll(cyclops2.async.Queue)