SynchronousQueue.clone fix

akarnokd · akarnokd · commit 67e8cfede63c · 2015-01-21T13:13:46.000+01:00
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

Original file line number	Diff line number	Diff line change
`@@ -138,7 +138,9 @@ public synchronized boolean offer(T e) {`
`138`	`138`
`139`	`139`	`@Override`
`140`	`140`	`public synchronized Object clone() {`
`141`		`- return list.clone();`
	`141`	`+ SynchronizedQueue<T> q = new SynchronizedQueue<T>(size);`
	`142`	`+ q.addAll(list);`
	`143`	`+ return q;`
`142`	`144`	`}`
`143`	`145`
`144`	`146`	`@Override`