This function should be invoked on any unwanted Observables returned from RPC to release the server resources.
fun <T> Observable<T>.notUsed(): Unit