- private CheckedFuture<DOMRpcResult, DOMRpcException> handleRpc(@Nonnull final SchemaPath type,
- @Nullable final NormalizedNode<?, ?> input,
- final MessageTransformer<NetconfMessage> transformer) {
- final NetconfMessage netconfMessage = transformer.toRpcRequest(type, input);
- final ListenableFuture<RpcResult<NetconfMessage>> rpcResultListenableFuture = listener.sendRequest(netconfMessage, type.getLastComponent());
-
- final ListenableFuture<DOMRpcResult> transformed = Futures.transform(rpcResultListenableFuture, new Function<RpcResult<NetconfMessage>, DOMRpcResult>() {
+ private @NonNull ListenableFuture<DOMRpcResult> handleRpc(final @NonNull QName type,
+ final @NonNull NormalizedNode input, final RpcTransformer transformer) {
+ final var delegateFuture = listener.sendRequest(transformer.toRpcRequest(type, input), type);
+ final var ret = SettableFuture.<DOMRpcResult>create();
+ Futures.addCallback(delegateFuture, new FutureCallback<>() {