Merge pull request #877 from pyrtsa/patch-1

Correct synchronization guard in groupByUntil
ReactiveX · Feb 14, 2014 · 2d921d1 · 2d921d1
2 parents ef023d1 + 4264229
commit 2d921d1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rxjava-core/src/main/java/rx/operators/OperationGroupByUntil.java b/rxjava-core/src/main/java/rx/operators/OperationGroupByUntil.java
@@ -102,7 +102,7 @@ public void onNext(TSource args) {
 
             GroupSubject<TKey, TResult> g;
             boolean newGroup = false;
-            synchronized (key) {
+            synchronized (gate) {
                 g = map.get(key);
                 if (g == null) {
                     g = create(key);