}

    public void modifiedToSpecified() {
        if (__modifiedProperties.isEmpty()) {
            return; // basically no way when called in Framework (because called when SpecifyColumn exists)
        }
        __specifiedProperties = newModifiedProperties();
        __specifiedProperties.accept(__modifiedProperties);
    }

    }

    public void modifiedToSpecified() {
        if (__modifiedProperties.isEmpty()) {
            return; // basically no way when called in Framework (because called when SpecifyColumn exists)
        }
        __specifiedProperties = newModifiedProperties();
        __specifiedProperties.accept(__modifiedProperties);
    }

        scriptExecutor.addShutdownListener(listener);

        // Verify listener not called yet
        assertFalse(listener.wasShutdownCalled());

        // Call shutdown
        scriptExecutor.shutdown();

        // Verify listener was called
        assertTrue(listener.wasShutdownCalled());
    }

    @Test
    public void test_shutdown_withoutListener() {

 *
 * <p>{@link #processBytes} will be called for each chunk of data that is read, and should return
 * {@code false} when you want to stop processing.
 *
 * @author Chris Nokleberg
 * @since 1.0
 */
@DoNotMock("Implement it normally")
@J2ktIncompatible
@GwtIncompatible
public interface ByteProcessor<T extends @Nullable Object> {
  /**

   * call this without consuming the complete response body, any remaining bytes in the response
   * body will be discarded before trailers are returned.
   *
   * If [Call.cancel] is called while this is blocking, this call will immediately throw.
   *
   * @throws IllegalStateException if the response is closed.
   * @throws IOException if the trailers cannot be loaded, such as if the network connection is

    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;
        }
    }

          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);

     * @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;
    }

    /**

        // 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]);

        try (SamrPolicyHandle handle = new SamrPolicyHandle(mockHandle, server, access)) {
            assertNotNull(handle);
            // Verify that sendrecv was called with MsrpcSamrConnect4
            verify(mockHandle, times(1)).sendrecv(any(MsrpcSamrConnect4.class));
            verify(mockHandle, never()).sendrecv(any(MsrpcSamrConnect2.class));
        }
    }

    @Test