Merge pull request #2475 from akarnokd/SyncQueueCloneFix

SynchronousQueue.clone fix
ReactiveX · Jan 21, 2015 · b359bb9 · b359bb9
2 parents 2af4f74 + 67e8cfe
commit b359bb9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/rx/internal/util/SynchronizedQueue.java b/src/main/java/rx/internal/util/SynchronizedQueue.java
@@ -138,7 +138,9 @@ public synchronized boolean offer(T e) {
 
     @Override
     public synchronized Object clone() {
-        return list.clone();
+        SynchronizedQueue<T> q = new SynchronizedQueue<T>(size);
+        q.addAll(list);
+        return q;
     }
 
     @Override