yougin
06/05/2017, 8:37 PMval subject = PublishSubject.create<Unit>()
subject.flatMap { Observable.empty<Unit>() }.subscribe({ println("onNext") },
{ println("error") },
{ println("onComplete") })
subject.onNext(Unit)