open fun rxClose(): Completable
Close the producer
Return
open fun rxClose(timeout: Long): Completable
timeout - timeout to wait for closing
timeout