Merge pull request #73 from robertroeser/master

compareAndSet

Author: stevegury

src/main/java/io/reactivesocket/ReactiveSocketFactory.java

@@ -104,16 +104,14 @@ public void onError(Throwable t) {
 
                     @Override
                     public void onComplete() {
-                        if (!complete.get()) {
-                            complete.set(true);
+                        if (complete.compareAndSet(false, true)) {
                             subscriber.onComplete();
                         }
                     }
                 });
 
             executorService.schedule(() -> {
-                if (!complete.get()) {
-                    complete.set(true);
+                if (complete.compareAndSet(false, true)) {
                     subscriber.onError(new TimeoutException());
                 }
             }, timeout, timeUnit);