- provisionRegistry.registerRpcImplementation(new DOMRpcImplementation() {
-
- @Override
- public CheckedFuture<DOMRpcResult, DOMRpcException> invokeRpc(DOMRpcIdentifier rpc, NormalizedNode<?, ?> input) {
- ContainerNode result = testContext.getCodec().getCodecFactory().toNormalizedNodeRpcData(output);
- return Futures.<DOMRpcResult, DOMRpcException>immediateCheckedFuture(new DefaultDOMRpcResult(result));
- }
+ provisionRegistry.registerRpcImplementation((rpc, input) -> {
+ ContainerNode result = testContext.getCodec().getCodecFactory().toNormalizedNodeRpcData(output);
+ return Futures.immediateCheckedFuture(new DefaultDOMRpcResult(result));