Method testException

src/test/java/org/sfj/ProxyMeTest.java:120–139

()

  }

  @Test
  public void testException() {
    AtomicReference<ProxyMe.Client<Closeable>> cRef = new AtomicReference<>(null);

    ProxyMe.Client<Closeable>
      client =
      new ProxyMe.Client<>(Executors.newScheduledThreadPool(1), Closeable.class,
        (i) -> cRef.get().complete(new ProxyMe.InvocationReturn<>(i.getIId(), null, new IOException())), 10,
        TimeUnit.MILLISECONDS);

    cRef.set(client);

    Closeable closeProxy = client.clientProxy(Thread.currentThread().getContextClassLoader());

    try {
      closeProxy.close();
      Assert.fail();
    } catch (IOException e) {
    }
  }
}