subscribe

open fun subscribe(completableEmitter: CompletableEmitter)