/*
     * We test that nullSingleton.retainAll(disjointList) does NOT throw a
     * NullPointerException when disjointList does not, so we can't use
     * MinimalCollection, which throws NullPointerException on calls to
     * contains(null).
     */
    List<E> disjointList = asList(e3(), e4());
    disjoint = new Target(disjointList, "disjoint");
    superset = new Target(MinimalCollection.of(e0(), e1(), e2(), e3(), e4()), "superset");

            assertEquals(expectedAlignedSize, echoRequest.size());
        }

        @Test
        @DisplayName("Size should be consistent across multiple calls")
        void testSizeConsistency() {
            int size1 = echoRequest.size();
            int size2 = echoRequest.size();

            assertEquals(size1, size2);
        }

        @Test

            }
        };

        // Execute stop
        dataStore.stop();

        assertTrue(stopCalled.get());
    }

    public void test_stop_multipleCalls() {
        // Test multiple stop calls
        final AtomicInteger stopCallCount = new AtomicInteger(0);

        dataStore = new DataStore() {
            @Override

  /**
   * True if this task faker has ever had multiple tasks scheduled to run concurrently. Guarded by
   * `this`.
   */
  var isParallel = false

  /** Number of calls to [TaskRunner.Backend.execute]. Guarded by `this`. */
  var executeCallCount = 0

  /** Guarded by [taskRunner]. */
  var nanoTime = 0L
    private set

   * method is called. Complete Futures here.
   */
  abstract void afterRanInterruptiblyFailure(Throwable error);

  /**
   * Interrupts the running task. Because this internally calls {@link Thread#interrupt()} which can
   * in turn invoke arbitrary code it is not safe to call while holding a lock.
   */
  @SuppressWarnings("Interruption") // We are implementing a user-requested interrupt.

  private @Nullable ThreadFactory backingThreadFactory = null;

  /**
   * Creates a new {@link ThreadFactory} builder.
   *
   * <p><b>Java 21+ users:</b> use {@link Thread#ofPlatform()} instead, translating other calls on
   * the builder as documented on each method (except for the rarely used {@link #setThreadFactory},
   * which does not have an equivalent).
   */
  public ThreadFactoryBuilder() {}

  /**

        verify(mockNdrBuffer).align(4);
        verify(mockNdrBuffer, times(2)).dec_ndr_long();
        verify(mockDeferredBuffer, times(3)).dec_ndr_long(); // 1 for array size + 2 for ShareInfo0 decode calls
        verify(mockDeferredBuffer).advance(8); // 4 * 2
    }

    @Test
    void testShareInfoCtr1EncodeWithArray() throws NdrException {
        srvsvc.ShareInfoCtr1 ctr1 = new srvsvc.ShareInfoCtr1();

    /** The URL of the API endpoint. */
    protected String url;

    /** The access timeout in seconds. */
    protected Integer accessTimeout; // sec

    /** The HTTP client used for API calls. */
    protected CloseableHttpClient httpClient;

    /** The connection timeout in milliseconds. */
    protected Integer connectionTimeout;

    /** The socket timeout in milliseconds. */

            oplockLevelField.setAccessible(true);
            oplockLevelField.set(notification, (byte) 0x01);

            // The implementation calls Hexdump.toHexString which throws NPE on null
            // This test verifies the actual behavior
            assertThrows(NullPointerException.class, () -> notification.toString());
        }

        @ParameterizedTest

public class DelegatingConfiguration implements Configuration {

    private final Configuration delegate;

    /**
     * Creates a delegating configuration that forwards calls to another configuration
     * @param delegate
     *            delegate to pass all non-overridden method calls to
     *
     */
    public DelegatingConfiguration(final Configuration delegate) {
        this.delegate = delegate;
    }

    /**