Readiness Race

Use success count to 2 to wait for both to occur.

Author: benjchristensen

src/main/java/io/reactivesocket/ReactiveSocket.java

@@ -224,19 +224,26 @@ public final void start(Completable c) {
 					errorStream,
 					c,
 					setupPayload -> {
-						requester = Requester.createServerRequester(new ConnectionFilter(connection, ConnectionFilter.STREAMS.FROM_SERVER_ODD), setupPayload, errorStream, new Completable() {
+						Completable two = new Completable() {
+
+							// wait for 2 success, or 1 error to pass on
+							AtomicInteger count = new AtomicInteger();
 
 							@Override
 							public void success() {
-								requesterReady.success();
+								if (count.incrementAndGet() == 2) {
+									requesterReady.success();
+								}
 							}
 
 							@Override
 							public void error(Throwable e) {
 								requesterReady.error(e);
 							}
 
-						});
+						};
+						requester = Requester.createServerRequester(new ConnectionFilter(connection, ConnectionFilter.STREAMS.FROM_SERVER_ODD), setupPayload, errorStream, two);
+						two.success(); // now that the reference is assigned in case of synchronous setup
 					});
 		} else {
 			Completable both = new Completable() {