- public static CheckedFuture<DOMRpcResult, DOMRpcException> from(final Future<Object> future) {
- return new RemoteDOMRpcFuture(future);
+ public static RemoteDOMRpcFuture create(final QName rpcName) {
+ return new RemoteDOMRpcFuture(rpcName);
+ }
+
+ protected void failNow(final Throwable error) {
+ LOG.debug("Failing future {} for rpc {}", this, rpcName, error);
+ setException(error);
+ }
+
+ protected void completeWith(final Future<Object> future) {
+ future.onComplete(new FutureUpdater(), ExecutionContext.Implicits$.MODULE$.global());