interesting, nevertheless

Guys, need you opinion on https://gist.github.com/stepango/c41a01a23bc986d82b8f20038c12e8a2

@stepango Mind if I ask what the

crossinline

is?

@pavlospt if you are passing lambda to anonymous class or another lambda in function body that marked as

inline

compiler need to generate different bytecode to allow returns from lambda you marked as

crossinline

. Any way if you'll try to compile this method without

crossinline

modifier you'll receive en compile time error

Hello , is there a method to create an observable from a list (like arraylist) in rx java 2? can't seem to find one

What is your choice? 1️⃣

Observable.just(listOf("foo", "bar")).filter { it.isNotEmpty() }

2️⃣

Observable.just(listOf("foo", "bar")).filter(Collection<*>::isNotEmpty)

how would you guys implement this scenario : Suppose we have an observable that emits something(for example strings) and we don't want the observable to emit anymore after something has happened (for example a particular string has been received) I don't want to unsubscribe from observer (that way i have to implement this strategy wherever the observable is subscribed to) , i just want the observable to stop and doonComplete when that item has been emited

I don't understand why not

first(predicate)

?

We do need the items , just till a particular item has been emitted for example think of an infinite observable that emits strings and you want to receive them until "test" has been emitted

oh thanks , i'll try that

What is the RxJava 2 equivalent of this:

observable.subscribe(subject)

?

Not sure how to get a

disposable

when subscribing with a normal

subject

.

you shouldn't subscribe a subject to a stream

i feel like it's mostly a historical accident that it every worked with 1.x

heh

so if I want to forward all events to a subject then I should just do it manually inside of a

DisposableObserver

why not just expose the observable directly downstream?

Do someone know how can I combineLatest from a dynamic list of observables?

what is a dynamic list?

there's a variant that takes a list of observables

yes but that in that list I want to add new observables

in uncertain time

and combinelatest their results

simply adding to a mutable list won't trigger combine latest to emit

switchOnNext

?

it’s not a list, yea

Yea good question @jw. I want a

switchMap

operator that completes only when any of the "inner" observables also completes. I was wrapping my upstream observable in a subject then switchMapping it so I could post a completion event to it when one of the inner ones completed.

actually switchOnNext is probably wrong, n/m. it unsubscribes from the previous observable when it switches.