- // Potentially acquire mount point list and interpret it
- final ListenableFuture<NetconfDeviceSchema> futureContext = Futures.transformAsync(futureSchema,
- result -> Futures.transform(createMountPointContext(result.modelContext(), baseSchema, listener),
- mount -> new NetconfDeviceSchema(result.capabilities(), mount), processingExecutor),
- processingExecutor);
-
- Futures.addCallback(futureContext, new FutureCallback<>() {
- @Override
- public void onSuccess(final NetconfDeviceSchema result) {
- handleSalInitializationSuccess(result, remoteSessionCapabilities,
- getDeviceSpecificRpc(result.mountContext(), listener, baseSchema), listener);
- }
+ Futures.addCallback(
+ // Potentially acquire mount point list and interpret it
+ Futures.transformAsync(futureSchema,
+ result -> Futures.transform(createMountPointContext(result.modelContext(), baseSchema, listener),
+ mount -> new NetconfDeviceSchema(result.capabilities(), mount), processingExecutor),
+ processingExecutor),
+ new FutureCallback<>() {
+ @Override
+ public void onSuccess(final NetconfDeviceSchema result) {
+ handleSalInitializationSuccess(listener, result, remoteSessionCapabilities,
+ getDeviceSpecificRpc(result.mountContext(), listener, baseSchema));
+ }