SynchronousQueue.clone fix

ReactiveX · Jan 21, 2015 · 67e8cfe · 67e8cfe
1 parent ec60fa4
commit 67e8cfe
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