Observable.toList breaks with multiple subscribers

[thegeez]

(let [i1 (Subject/create)
        out (Observable/toList i1)]
    (.subscribe out (partial prn "first observer"))
    (.subscribe out (partial prn "second observer"))
    (.subscribe out (partial prn "third observer"))
    (.onNext i1 1)
    (.onNext i1 2)
    (.onNext i1 3)
    (.onNext i1 4)
    (.onNext i1 5)
    (.onNext i1 6)
    (.onCompleted i1))

Output:

"first observer" [1 1 1 2 2 2 3 3 3 4 4 4 5 5 5 6 6 6]
"second observer" [1 1 1 2 2 2 3 3 3 4 4 4 5 5 5 6 6 6]
"third observer" [1 1 1 2 2 2 3 3 3 4 4 4 5 5 5 6 6 6]

Should be:

"first observer" [1 2 3 4 5 6]
"second observer" [1 2 3 4 5 6]
"third observer" [1 2 3 4 5 6]

[cloudbees-pull-request-builder]

RxJava-pull-requests #48 SUCCESS
This pull request looks good

[benjchristensen]

Good change ... that was a silly mistake on my part, sorry about that and thank you for submitting a fix.