ArgumentCaptor<Smb2ReadRequest> cap = ArgumentCaptor.forClass(Smb2ReadRequest.class);
            verify(mockTree).send(cap.capture(), any(RequestParam.class));
            Smb2ReadRequest req = cap.getValue();

            // Reflectively inspect the private 'offset' field to assert it used the advanced fp
            Field offField = Smb2ReadRequest.class.getDeclaredField("offset");
            offField.setAccessible(true);

        ArgumentCaptor<CommonServerMessageBlockRequest> reqCap = ArgumentCaptor.forClass(CommonServerMessageBlockRequest.class);
        verify(tree).send(reqCap.capture(), any(), any(), any());
        assertTrue(reqCap.getValue() instanceof Smb2ChangeNotifyRequest, "SMB2 request must be used");
        verify(tree, times(1)).close(); // try-with-resources must close
        verify(handle, never()).markClosed();

  static <K, V> ImmutableMap<K, V> asImmutable(Map<K, V> map) {
    for (Entry<K, V> entry : checkNotNull(map).entrySet()) {
      checkNotNull(entry.getKey());
      checkNotNull(entry.getValue());
    }
    return new ImmutableEnumMap<K, V>(map);
  }

  private ImmutableEnumMap(Map<? extends K, ? extends V> delegate) {
    super(delegate);
  }

        final CrawlingInfoParam param = new CrawlingInfoParam();
        assertNull(param.getId());
        assertNull(param.getCrawlingInfoId());
        assertNull(param.getKey());
        assertNull(param.getValue());
        assertNull(param.getCreatedTime());

        param.setId("param-id");
        param.setCrawlingInfoId("crawling-info-id");
        param.setKey("docs_processed");
        param.setValue("1000");

                if (e.getValue() != null) {
                    if (!first) {
                        json.append(",");
                    }
                    json.append("\"").append(escapeJson(e.getKey())).append("\":\"");
                    json.append(escapeJson(String.valueOf(e.getValue()))).append("\"");
                    first = false;
                }

    for (Entry<String, String> entry : TEST_STRINGS.entrySet()) {
      if (testAsCharSource) {
        suite.addTest(suiteForString(factory, entry.getValue(), name, entry.getKey()));
      } else {
        suite.addTest(
            suiteForBytes(factory, entry.getValue().getBytes(UTF_8), name, entry.getKey(), true));
      }
    }
    return suite;
  }

  static TestSuite suiteForString(

            ArgumentCaptor<MsrpcSamrConnect4> captor = ArgumentCaptor.forClass(MsrpcSamrConnect4.class);
            verify(mockHandle).sendrecv(captor.capture());
            assertEquals("\\\\", captor.getValue().system_name); // Verify server name in RPC call
        }
    }

    @Test
    void testConstructor_FallbackToConnect2() throws IOException {

        ArgumentCaptor<String> pathCap = ArgumentCaptor.forClass(String.class);
        verify(locator).handleDFSReferral(drCap.capture(), pathCap.capture());

        assertSame(referral, drCap.getValue());
        assertEquals(req, pathCap.getValue());
        verifyNoMoreInteractions(locator);
    }

    ChannelState(int value) {
        this.value = value;
    }

    /**
     * Get the numeric value of this state
     *
     * @return state value
     */
    public int getValue() {
        return value;
    }

    private final int value;

    HandleType(int value) {
        this.value = value;
    }

    /**
     * Get the numeric value of this handle type
     * @return the numeric value
     */
    public int getValue() {
        return value;
    }

    /**
     * Get HandleType from numeric value
     * @param value the numeric value
     * @return the corresponding HandleType
     */