@Override
  public T get() {
    try {
      while (hasMore()) {
        final T value = queue.poll(1, TimeUnit.SECONDS);
        if (value != null) {
          outputCounter.inc();
          return value;
        }
      }
    } catch (final InterruptedException e) {
      LOG.trace("Interrupted while waiting for next item from pipe {}", pipeName);
    }
    return null;
  }
Get the name of this pipe

@return the name of the pipe
services/pipeline/src/main/java/org/hyperledger/besu/services/pipeline/Pipe.java