diff options
| -rw-r--r-- | central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java index a70385b..5f7e8a1 100644 --- a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java +++ b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java @@ -83,9 +83,8 @@ class ProvisionRemoteServiceImpl implements IProvisionRemoteService { .<Void>compose(reply -> Future.succeededFuture(null)) .onComplete(res -> channel.shutdown()); }) - .compose(_v -> { + .onComplete(_v -> { lock.release(); - return Future.succeededFuture(); }); }) .onFailure(err -> logger.error("Cannot deploy to " + nodeId, err)) |