Yeah I was thinking that. Should return a `Subscription` that closes the subject and removes the internal listener.

Would be good to have unit tests too. Have a look at the existing Android specific classes to see how we use Robolectric to test them.

I'm also getting a weird compilation error in IntelliJ (it says `PublishSubject<float[]>` is not a subtype of `Observable<float[]>`, but it builds fine using Gradle, so that might be an issue with my IDE setup?

Apart from that looks good to me. @benjchristensen I was wondering though, in what way does this not merge cleanly? I don't see with what this would conflict and GH isn't reporting merge conflicts for me.