whitouht having to save the state outside the chain

can you point me to an operator / site ?

Hi guys, is there a better way to write that:

RxHelper.deployVerticle(vertx, ConfigurationVerticle())
                    .doOnCompleted({
                        RxHelper.deployVerticle(vertx, RunnerVerticle())
                                .doOnCompleted({
                                    RxHelper.deployVerticle(vertx, FBRestVerticle()).subscribe()
                                }).subscribe()
                    }).subscribe()

The goal is to deploy all my verticles

try andThen

thanks

I want to do something like the following:

read.subscribeOn(<http://Schedulers.io|Schedulers.io>())
        .take(1)
        .takeWhile { (it and 0x80.toByte()) == 0.toByte()} 
        .take(n)

Except that

n

is a value that I determine based on the bytes I caught through

takeWhile

. How can I fetch this value before performing the

take(n)

?

I think

var n: Int = 0
read.subscribeOn(<http://Schedulers.io|Schedulers.io>())
        .take(1)
        .takeWhile {
            n += (it % 0x80.toByte).toInt()
            (it and 0x80.toByte()) == 0.toByte()
        }.take(n)

Isn't ideal

Why take(1) then takeUntil?

Hi guys, is it possible to return different types inside onNext and onComplete, I would like to return onNext(Pair<String,MessageBody>) and onComplete(MessageBody)

You can't, since

onNext

and

onComplete

belongs to the same stream, they must be the same type

But you can do a little trick to make this work, instead of doing in

onNext

, do it in

doOnNext

and the before the stream ends, apply a `map`to transform it into

MessageBody

ok that’s what I understood 😞

thanks for the trick

guys, when i create an obs from Observable.create, how do i call onNext from outside of it?

@myanmarking You rather use a subject

Even though you could store the emitter in a field, but that's kind of hacky

i want to use it in a combinelatest

will it work

Depending on what you do, but yes generally you need to use an observable in combine latest, so you are free to do what ever you want 😉

subject.toFlowable will work tho

Hi, I need to filter a map with the result of an Observable,

node.outgoingLinks
                        .toObservable()
                        .filter { it.checkCondition(messageBody) }
                        .map { it.eventName }

and it.checkCondition return an observable I don’t know how to do this

I think you can try to flatMap and filter/map the result of the checkCOndition observable

something like

that being said in your case messageBody seems to be known and is not related to the outgoingLinks observable

so you should probably check the condition ahead of time

which is maybe less rx-ish

but more practical

ok thanks, I also can move executeBlocking outside the check condition method

like

return vertx.rxExecuteBlocking<List<String>> { future ->
            val eventNamesToEmit = mutableListOf<String>()

            eventNamesToEmit.addAll(
                    node.outgoingLinks
                            .filter { it.checkCondition(messageBody) }
                            .map { it.eventName }
            )
            if (eventNamesToEmit.isEmpty()) {
                eventNamesToEmit.addAll(
                        node.outgoingLinks
                                .filter { it is ConditionalLink }
                                .filter { (it as ConditionalLink).condition == Condition.ELSE }
                                .map { it.eventName }
                )

            }
            future.complete(eventNamesToEmit)
        }

In that way I can just return a Boolean for checkCondition