open fun rxClose(): Single<Void>
Close the producer
Return
open fun rxClose(timeout: Long): Single<Void>
timeout - timeout to wait for closing
timeout