Implement change stream as `Observable`

[satabin]

A cleaner way to implement continuous change stream is to expose it as an observable from rxjava-scala. This will lead to much more stable change stream API