private boolean called = false;

          @Override
          public void onSuccess(String result) {
            fail("Was not expecting onSuccess() to be called.");
          }

          @Override
          public void onFailure(Throwable t) {
            synchronized (monitor) {
              assertFalse(called);
              assertThat(t).isInstanceOf(CancellationException.class);

    static class TestSigningDigest extends SigningDigest {
        boolean called;
        int lastLength;

        TestSigningDigest() throws SmbException {
            super(new byte[16], false);
        }

        @Override
        void sign(byte[] data, int offset, int length, ServerMessageBlock request, ServerMessageBlock response) {
            called = true;
            lastLength = length;
        }
    }

     * @param encoding the encoding
     * @return this CurlRequest instance
     * @throws CurlException if the method is called after the param method
     */
    public CurlRequest encoding(final String encoding) {
        if (paramList != null) {
            throw new CurlException("This method must be called before param method.");
        }
        this.encoding = encoding;
        return this;
    }

    /**

    toPut.put(null, 1);
    ImmutableSetMultimap.Builder<String, Integer> builder = ImmutableSetMultimap.builder();
    assertThrows(NullPointerException.class, () -> builder.put(null, 1));
    assertThrows(NullPointerException.class, () -> builder.putAll(null, Arrays.asList(1, 2, 3)));
    assertThrows(NullPointerException.class, () -> builder.putAll(null, 1, 2, 3));
    assertThrows(

        // Execute
        String result = purgeLogJob.execute();

        // Assert crawling info and status update were called
        assertTrue(deleteCrawlingInfoCalled[0]);
        assertTrue(updateJobLogStatusCalled[0]);

        // Assert other services were not called
        assertFalse(deleteSearchLogCalled[0]);
        assertFalse(deleteJobLogCalled[0]);
        assertFalse(deleteUserInfoCalled[0]);

FIELD com.google.common.util.concurrent.ExecutionSequencer.ThreadConfinedTaskQueue.nextExecutor com.google.common.util.concurrent.ExecutionSequencer.TaskNonReentrantExecutor
# Real cycle, but the runningState field is null'ed on completion of the future.
FIELD com.google.common.util.concurrent.AggregateFuture.runningState
FIELD java.util.AbstractMap.keySet com.google.common.collect.AbstractMapBasedMultimap.NavigableKeySet

            // Verify that sendrecv was called with MsrpcSamrConnect4
            verify(mockHandle, times(1)).sendrecv(any(MsrpcSamrConnect4.class));
            verify(mockHandle, never()).sendrecv(any(MsrpcSamrConnect2.class));
        }
    }

    @Test
    void testConstructor_NullServer() throws IOException {
        // Test case: Constructor with null server, should default to "\\\\"
        String server = null;

     *
     * @param level the logging level to set
     */
    public static void setLevel(final int level) {
        LogStream.level = level;
    }

    /**
     * This must be called before <code>getInstance</code> is called or
     * it will have no effect.
     *
     * @param stream the PrintStream to use for logging
     */
    public static void setInstance(final PrintStream stream) {

   * initial write to timer is never definitely visible to Fire.run since it is assigned after
   * SES.schedule is called. Therefore Fire.run has to check for null. However, it should be visible
   * if Fire.run is called by delegate.addListener since addListener is called after the assignment
   * to timer, and importantly this is the main situation in which we need to be able to see the
   * write.
   *

        assertFalse(emptyGenerator.generate(null, outputFile));
        assertFalse(emptyGenerator.generate("thumbnailId", null));
        assertFalse(emptyGenerator.generate(null, null));
    }

    @Test
    public void test_destroy() {
        // Initialize without container
        emptyGenerator = new EmptyGenerator();

        // Test that destroy method can be called without error
        emptyGenerator.destroy();