super(config, SMB2_ECHO);
    }

    @Override
    protected Smb2EchoResponse createResponse(final CIFSContext tc, final ServerMessageBlock2Request<Smb2EchoResponse> req) {
        return new Smb2EchoResponse(tc.getConfig());
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override
    public int size() {

        super(config, SMB2_LOGOFF);
    }

    @Override
    protected Smb2LogoffResponse createResponse(final CIFSContext tc, final ServerMessageBlock2Request<Smb2LogoffResponse> req) {
        return new Smb2LogoffResponse(tc.getConfig());
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.CommonServerMessageBlockRequest#size()
     */
    @Override
    public int size() {

    public FatArtifactTraverser() {}

    @Override
    public boolean traverseDependency(Dependency dependency) {
        requireNonNull(dependency, "dependency cannot be null");
        String prop = dependency.getArtifact().getProperty(MavenArtifactProperties.INCLUDES_DEPENDENCIES, "");
        return !Boolean.parseBoolean(prop);
    }

    @Override

    super(delegate);
    this.delegate = delegate;
  }

  @Override
  public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
    return delegate.schedule(wrapTask(command), delay, unit);
  }

  @Override
  public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
      Callable<V> task, long delay, TimeUnit unit) {

    private class PushObserverCancel : PushObserver {
      override fun onRequest(
        streamId: Int,
        requestHeaders: List<Header>,
      ): Boolean = true

      override fun onHeaders(
        streamId: Int,
        responseHeaders: List<Header>,
        last: Boolean,
      ): Boolean = true

      @Throws(IOException::class)
      override fun onData(
        streamId: Int,

    new IteratorTester<E>(
        4,
        MODIFIABLE,
        getSubjectGenerator().order(asList(e0(), e1(), e1(), e2())),
        IteratorTester.KnownOrder.KNOWN_ORDER) {
      @Override
      protected Iterator<E> newTargetIterator() {
        return getSubjectGenerator().create(e0(), e1(), e1(), e2()).iterator();
      }
    }.test();
  }

      values.add(null);
    }

    this.values = values;
  }

  @Override
  final void collectOneValue(int index, @ParametricNullness V returnValue) {
    @RetainedLocalRef List<@Nullable Present<V>> localValues = values;
    if (localValues != null) {
      localValues.set(index, new Present<>(returnValue));
    }
  }

  @Override
  final void handleAllCompleted() {

/**
 * An implementation of I/O for `PublicSuffixDatabase` by directly passing in ByteStrings.
 */
internal class ConfiguredPublicSuffixList : PublicSuffixList {
  override fun ensureLoaded() {
  }

  override var bytes: ByteString = ByteString.EMPTY

  override var exceptionBytes: ByteString = ByteString.EMPTY

        remainingCountUpdater = newUpdater(AggregateFutureState.class, "remainingField");

    @Override
    void compareAndSetSeenExceptions(
        AggregateFutureState<?> state, @Nullable Set<Throwable> expect, Set<Throwable> update) {
      seenExceptionsUpdater.compareAndSet(state, expect, update);
    }

    @Override
    int decrementAndGetRemainingCount(AggregateFutureState<?> state) {

        this.enumeration = enumeration;
    }

    @Override
    public void remove() {
        throw new ClUnsupportedOperationException("remove");
    }

    @Override
    public boolean hasNext() {
        return enumeration.hasMoreElements();
    }

    @Override
    public T next() {
        return enumeration.nextElement();
    }