@Test public void invokeOnTest() throws Exception { final MethodHandle methodHandle = MethodHandles.lookup().unreflect( TestImplClassWithInput.class.getDeclaredMethod("testMethod", RpcService.class, DataObject.class)); final RpcMethodInvokerWithInput rpcMethodInvokerWithInput = new RpcMethodInvokerWithInput(methodHandle); assertNotNull(rpcMethodInvokerWithInput.invokeOn(TEST_IMPL_CLASS, null)); }
@Override @SuppressWarnings("checkstyle:illegalCatch") ListenableFuture<RpcResult<?>> invokeOn(final RpcService impl, final DataObject input) { try { return (ListenableFuture<RpcResult<?>>) handle.invokeExact(impl,input); } catch (Throwable e) { Throwables.throwIfUnchecked(e); throw new IllegalStateException(e); } }
RpcMethodInvokerWithInput extends RpcMethodInvoker { @Override @SuppressWarnings("checkstyle:illegalCatch") ListenableFuture<RpcResult<?>> invokeOn(final RpcService impl, final DataObject input) { try { return (ListenableFuture<RpcResult<?>>) handle.invokeExact(impl,input); } catch (Throwable e) { Throwables.throwIfUnchecked(e); throw new IllegalStateException(e); } } }
RpcMethodInvokerWithInput extends RpcMethodInvoker { @Override @SuppressWarnings("checkstyle:illegalCatch") ListenableFuture<RpcResult<?>> invokeOn(final RpcService impl, final DataObject input) { try { return (ListenableFuture<RpcResult<?>>) handle.invokeExact(impl,input); } catch (Throwable e) { Throwables.throwIfUnchecked(e); throw new IllegalStateException(e); } } RpcMethodInvokerWithInput(final MethodHandle methodHandle); }
RpcMethodInvokerWithInput extends RpcMethodInvoker { @Override @SuppressWarnings("checkstyle:illegalCatch") ListenableFuture<RpcResult<?>> invokeOn(final RpcService impl, final DataObject input) { try { return (ListenableFuture<RpcResult<?>>) handle.invokeExact(impl,input); } catch (Throwable e) { Throwables.throwIfUnchecked(e); throw new IllegalStateException(e); } } RpcMethodInvokerWithInput(final MethodHandle methodHandle);  }
RpcMethodInvokerWithInput extends RpcMethodInvoker { @Override @SuppressWarnings("checkstyle:illegalCatch") ListenableFuture<RpcResult<?>> invokeOn(final RpcService impl, final DataObject input) { try { return (ListenableFuture<RpcResult<?>>) handle.invokeExact(impl,input); } catch (Throwable e) { Throwables.throwIfUnchecked(e); throw new IllegalStateException(e); } } RpcMethodInvokerWithInput(final MethodHandle methodHandle);   }