I was expecting to get a terminal event, but this ...
# rx
y
I was expecting to get a terminal event, but this didn’t happen, am I missing something? (RxJava2)
Copy code
val subject = PublishSubject.create<Unit>()
    subject.flatMap { Observable.empty<Unit>() }.subscribe({ println("onNext") },
                                                           { println("error") },
                                                           { println("onComplete") })
    subject.onNext(Unit)