Ok, so.. .I have this code ``` v...

# rx

[juliocbcotta]

Ok, so.. .I have this code

val subject: PublishSubject<String> = PublishSubject.create()

                subject
                .toFlowable(BackpressureStrategy.BUFFER)
                .startWith(getInitialNodeId())
                .flatMap({
                    repository
                            .loadNextItemInASingle(it)
                            .toFlowable()
                })
                .doOnNext({
                    if (it.type == START) {
                        subject.onNext(it.nextId)
                    }
                })

and when I receive a it.type == START the doOnNext should make the subject emit a new item… but it seems it does not happen…. Any ideas?