@Test
        @DisplayName("toString with null challenge throws NPE")
        void testToStringWithNullChallengeThrowsNPE() {
            UniAddress dc = mock(UniAddress.class);
            when(dc.toString()).thenReturn("ANYSERVER");

            NtlmChallenge nc = new NtlmChallenge(null, dc);

            // Hexdump.toHexString will throw NPE when accessing challenge.length

            if (throwExceptionOnReadParameters) {
                throw new SMBProtocolDecodingException("Test exception in readParametersWireFormat");
            }
            return parametersWireFormatReturn;
        }

        @Override
        protected int readDataWireFormat(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {

   * @throws IllegalArgumentException if the object was not previously registered.
   */
  public void unregister(Object object) {
    subscribers.unregister(object);
  }

  /**
   * Posts an event to all registered subscribers. This method will return successfully after the
   * event has been posted to all subscribers, and regardless of any exceptions thrown by
   * subscribers.
   *

    private void setPrivateField(Object obj, String fieldName, Object value) throws Exception {
        Field field = obj.getClass().getDeclaredField(fieldName);
        field.setAccessible(true);
        field.set(obj, value);
    }

    /**
     * Helper method to get private field value using reflection
     */
    private Object getPrivateField(Object obj, String fieldName) throws Exception {

   * synchronized.
   */
  @VisibleForTesting
  void invokeSubscriberMethod(Object event) throws InvocationTargetException {
    try {
      method.invoke(target, checkNotNull(event));
    } catch (IllegalArgumentException e) {
      throw new Error("Method rejected target/argument: " + event, e);
    } catch (IllegalAccessException e) {
      throw new Error("Method became inaccessible: " + event, e);
    } catch (InvocationTargetException e) {

    }

    public void test_getProcess() throws IOException {
        Process mockProcess = createMockProcess("test");
        JobProcess jobProcess = new JobProcess(mockProcess);

        Process retrievedProcess = jobProcess.getProcess();

        assertSame(mockProcess, retrievedProcess);
    }

    public void test_getInputStreamThread() throws IOException {

## Version 2.4.0-RC1

_2015-05-16_

 *  **New HttpUrl API.** It's like `java.net.URL` but good. Note that
    `Request.Builder.url()` now throws `IllegalArgumentException` on malformed
    URLs. (Previous releases would throw a `MalformedURLException` when calling
    a malformed URL.)

 *  **We've improved connect failure recovery.** We now differentiate between

        handleManager.completeReconnect(handle.path, true);
    } else {
        handleManager.completeReconnect(handle.path, false);
        throw new IOException("Failed to reconnect durable handle");
    }
}

@Override
public void close() throws IOException {
    try {
        // Normal close operations
        super.close();
    } finally {

    assertEquals(6, (int) future.get());
  }

  public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
    Runnable runnable =
        new Runnable() {
          @Override
          public void run() {
            throw new RuntimeException("Oh no!");
          }
        };

    Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);

    assertEquals(6, (int) future.get());
  }

  public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
    Runnable runnable =
        new Runnable() {
          @Override
          public void run() {
            throw new RuntimeException("Oh no!");
          }
        };

    Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);