(question) how can I show the task progress with RxJava?

[letroll]

No description provided.

[abersnaze]

This is a snippet of groovy code that will probably do most of what you want.

input = from([1,2,3,4])

// we are going to be branching off of the input observable three times so cache it.
cached = input.cache()

// produce an observable that is the fraction completed. In this case 0.25, 0.5, 0.75, 1
fract = cached.reduce(0, {count,value -> count+1}).mapMany({size -> cached.mapWithIndex({value,index -> (index+1)/size})})

// zip the fraction observable with the values to sync the timing of the values coming out with the fraction of completion
output = Observable.zip(cached,fract, {value, fractionDone ->
    // side effect to update progress bar with fraction done.
    println "done $fractionDone"
    return value
})

// OR

// if updating the status of a progress bar produces an observable you'll have to use this for the last zip
output = Observable.merge(Observable.zip(cached,fract, {value, fractionDone ->
    // operation to update progress bar with fraction done results in an observable too
    update = just("done $fractionDone")

    return zip(just(value), update, {value2, updateStatus -> value2})
}))

[benjchristensen]

Closing out ... further conversation can be taken up on https://groups.google.com/d/forum/rxjava