Hi all, If I use `Completable.create { }` the `C...

# rx

[muthuraj]

Hi all,

If I use Completable.create { } the CompletableOnSubscribe becomes null.
Completable.create((CompletableOnSubscribe)null.INSTANCE); this is the decompiled version.
Since it becomes null, anything I put inside create doesn’t work.

But if I use

Completable.create(object : CompletableOnSubscribe{

override fun subscribe(e: CompletableEmitter?) {

}

})

like this, then it is working fine.

[leosan]

muthuraj: I’ve just tried that and it is working fine

Completable.create { emitter ->
                //myCode
                emitter.onComplete()
            }

[muthuraj]

Are you sure? I’m getting null.INSTANCE on decompiled class. Also on debugging, the emitter value is always null.