* character. This has the effect of creating an escaper which has no well-defined inverse but it
   * can be useful when escaping additional characters.
   *
   * @param safeChars a non-null string specifying additional safe characters for this escaper (the
   *     ranges 0..9, a..z and A..Z are always safe and should not be specified here)

        verify(watchHandle, times(3)).watch();
    }

    /**
     * Test watch() returning null (cancelled scenario)
     */
    @Test
    void testWatchReturnsNull() throws CIFSException {
        // Setup mock behavior
        when(watchHandle.watch()).thenReturn(null);

        // Execute
        List<FileNotifyInformation> result = watchHandle.watch();

        // Verify

			} else {
				return errNonNumericArg(funcName)
			}
		}
	}

	// Mark that we have seen one non-null value.
	isFirstRow := false
	if !e.aggregate.seen {
		e.aggregate.seen = true
		isFirstRow = true
	}

	switch funcName {
	case aggFnCount:
		// For all non-null values, the count is incremented.
		e.aggregate.runningCount++

	case aggFnAvg, aggFnSum:
		e.aggregate.runningCount++

  public SampleHttpClient() {
    client = new OkHttpClient.Builder().build();
  }

  public void makeCall(HttpUrl url) throws IOException {
    try (Response response = client.newCall(new Request(url, Headers.EMPTY, "GET", null)).execute()) {
      System.out.println(response.body().string());
    }
  }

/**
 * A proxy selector that always returns the [Proxy.NO_PROXY].
 */
object NullProxySelector : ProxySelector() {
  override fun select(uri: URI?): List<Proxy> {
    requireNotNull(uri) { "uri must not be null" }
    return listOf(Proxy.NO_PROXY)
  }

  override fun connectFailed(
    uri: URI?,
    sa: SocketAddress?,
    ioe: IOException?,
  ) {
  }

        MsrpcGetMembersInAlias msrpcGetMembersInAlias = new MsrpcGetMembersInAlias(mockAliasHandle, mockSids);

        // Then
        assertNotNull(msrpcGetMembersInAlias, "MsrpcGetMembersInAlias object should not be null");
        assertEquals(mockSids, msrpcGetMembersInAlias.sids, "sids should be set correctly");
        assertEquals(0, msrpcGetMembersInAlias.getPtype(), "ptype should be initialized to 0");

 */
public class ReplaceKeyInMatch extends ReplaceByKey {

    public ReplaceKeyInMatch(String replaceKey, String newKeyName, String testName) {
        super(replaceKey, newKeyName, null, testName);
    }

    @Override
    @Internal
    public String getKeyToFind() {
        return "match";
    }

    @Override
    public void transformTest(ObjectNode matchParent) {

    Builder<String, Integer> builder = new Builder<>();
    assertThrows(
        NullPointerException.class, () -> builder.put(immutableEntry("one", (Integer) null)));
    assertThrows(NullPointerException.class, () -> builder.put(immutableEntry((String) null, 1)));
  }

  public void testBuilderWithExpectedKeysNegative() {
    assertThrows(

        classLoader.loadClass(AggregateFutureState.class.getName());
    Field helperField = aggregateFutureStateClass.getDeclaredField("ATOMIC_HELPER");
    helperField.setAccessible(true);
    assertThat(helperField.get(null).getClass().getSimpleName()).isEqualTo(expectedHelperClassName);
  }

  private static ClassLoader getClassLoader(Set<String> blocklist) {
    String concurrentPackage = SettableFuture.class.getPackage().getName();

  static <T extends Throwable> T assertThrows(
      Class<T> expectedThrowable, ThrowingRunnable runnable) {
    return doAssertThrows(
        expectedThrowable,
        () -> {
          runnable.run();
          return null;
        },
        /* userPassedSupplier= */ false);
  }

  private static <T extends Throwable> T doAssertThrows(
      Class<T> expectedThrowable, ThrowingSupplier supplier, boolean userPassedSupplier) {