Skip to content

Commit 3965890

Browse files
authored
Remove ClusterImpl#isShutdown method (#373)
1 parent d04afe7 commit 3965890

File tree

3 files changed

+0
-13
lines changed

3 files changed

+0
-13
lines changed

cluster-api/src/main/java/io/scalecube/cluster/Cluster.java

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -141,11 +141,4 @@ public interface Cluster {
141141
* @return promise which is completed once graceful shutdown is finished.
142142
*/
143143
Mono<Void> onShutdown();
144-
145-
/**
146-
* Check if cluster instance has been shut down.
147-
*
148-
* @return returns true if cluster instance has been shut down; false otherwise.
149-
*/
150-
boolean isShutdown();
151144
}

cluster/src/main/java/io/scalecube/cluster/ClusterImpl.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -558,11 +558,6 @@ public Mono<Void> onShutdown() {
558558
return onShutdown.asMono();
559559
}
560560

561-
@Override
562-
public boolean isShutdown() {
563-
return onShutdown.asMono().toFuture().isDone();
564-
}
565-
566561
private static class SenderAwareTransport implements Transport {
567562

568563
private final Transport transport;

cluster/src/test/java/io/scalecube/cluster/ClusterTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -471,7 +471,6 @@ public void onMembershipEvent(MembershipEvent event) {
471471

472472
node2.shutdown();
473473
node2.onShutdown().block(TIMEOUT);
474-
assertTrue(node2.isShutdown());
475474

476475
assertTrue(leavingLatch.await(TIMEOUT.getSeconds(), TimeUnit.SECONDS));
477476
assertTrue(removedLatch.await(TIMEOUT.getSeconds(), TimeUnit.SECONDS));

0 commit comments

Comments
 (0)