*  New: `mockwebserver3.SocketPolicy` is now a sealed interface. This is one of several
    backwards-incompatible API changes that may impact early adopters of this alpha API.

 *  New: `mockwebserver3.Stream` for duplex streams.

 *  New: `mockwebserver3.MockResponseBody` for streamed response bodies.

 *  New: `mockwebserver3.MockResponse` is now immutable, with a `Builder`.

        return new CurlRequest(Method.POST, url);
    }

    /**
     * Creates a new CurlRequest with the HTTP PUT method for the specified URL.
     *
     * @param url the URL to which the PUT request will be sent
     * @return a new CurlRequest object configured with the PUT method and the specified URL
     */
    public static CurlRequest put(final String url) {
        return new CurlRequest(Method.PUT, url);
    }

```java
public class LeaseStatistics {
    private final AtomicLong leasesRequested = new AtomicLong();
    private final AtomicLong leasesGranted = new AtomicLong();
    private final AtomicLong leaseBreaks = new AtomicLong();
    private final AtomicLong leaseUpgrades = new AtomicLong();
    private final AtomicLong leaseDowngrades = new AtomicLong();
    
    // Getters and increment methods
}
```

    void testWriteBytesWireFormatWithEmptyToken() throws Exception {
        // Given
        byte[] emptyToken = new byte[0];
        Smb2SessionSetupRequest req =
                new Smb2SessionSetupRequest(mockContext, TEST_SECURITY_MODE, TEST_CAPABILITIES, TEST_PREVIOUS_SESSION_ID, emptyToken);
        byte[] buffer = new byte[512];

        // When
        req.encode(buffer, 0);

        // Then

        final CountDownLatch startLatch = new CountDownLatch(1);
        final CountDownLatch endLatch = new CountDownLatch(2);
        final AtomicInteger successCount = new AtomicInteger(0);

        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    startLatch.await();

    /**
     * Creates a new empty DataStoreParams instance.
     * Initializes the internal parameter map with a ParamMap wrapper.
     */
    public DataStoreParams() {
        params = new ParamMap<>(new HashMap<>());
    }

    /**
     * Creates a new DataStoreParams instance with a copy of the provided parameters.
     * This protected constructor is used for creating new instances from existing parameter maps.
     *

    public Class<?>[] createKeyArray(int length) {
      return new Class<?>[length];
    }

    @Override
    public Impl[] createValueArray(int length) {
      return new Impl[length];
    }

    @Override
    public SampleElements<Entry<Class, Impl>> samples() {
      return new SampleElements<>(
          immutableEntry((Class) One.class, new Impl(1)),
          immutableEntry((Class) Two.class, new Impl(2)),

  private final TearDownStack tearDownStack = new TearDownStack(true);
  private final CountDownLatch enterRun = new CountDownLatch(1);
  private final CountDownLatch exitRun = new CountDownLatch(1);

  private Thread executionThread;
  private Throwable thrownByExecutionThread;
  private final Executor exceptionCatchingExecutor =
      new Executor() {
        @Override
        public void execute(Runnable command) {

            _specification = new HpSpecification();
        }
        return _specification;
    }

    protected void assertQueryPurpose() {
    }

    protected void assertAggregationPurpose() {
    }

    protected void assertSpecifyPurpose() {
    }

    public static class HpSpecification {
        protected List<String> columnList = new ArrayList<>();

            _specification = new HpSpecification();
        }
        return _specification;
    }

    protected void assertQueryPurpose() {
    }

    protected void assertAggregationPurpose() {
    }

    protected void assertSpecifyPurpose() {
    }

    public static class HpSpecification {
        protected List<String> columnList = new ArrayList<>();