Merge pull request rsocket#73 from robertroeser/master

stevegury · stevegury · commit e9b59a09bf9f · 2016-03-30T11:21:10.000-07:00
compareAndSet
diff --git a/src/main/java/io/reactivesocket/ReactiveSocketFactory.java b/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);

Original file line number	Diff line number	Diff line change
`@@ -104,16 +104,14 @@ public void onError(Throwable t) {`
`104`	`104`
`105`	`105`	`@Override`
`106`	`106`	`public void onComplete() {`
`107`		`- if (!complete.get()) {`
`108`		`- complete.set(true);`
	`107`	`+ if (complete.compareAndSet(false, true)) {`
`109`	`108`	`subscriber.onComplete();`
`110`	`109`	`}`
`111`	`110`	`}`
`112`	`111`	`});`
`113`	`112`
`114`	`113`	`executorService.schedule(() -> {`
`115`		`- if (!complete.get()) {`
`116`		`- complete.set(true);`
	`114`	`+ if (complete.compareAndSet(false, true)) {`
`117`	`115`	`subscriber.onError(new TimeoutException());`
`118`	`116`	`}`
`119`	`117`	`}, timeout, timeUnit);`