In the event we did a pure Rx implementation in Kotlin, would it make sense

observeOn()

,

subscribeOn()

, and

unsubscribeOn()

would directly accept a

CoroutineDispatcher

instead of a

Scheduler

backed by a

CoroutineDispatcher

?

It hides it. You can't cast it after hide() and manipulate it.

refcount maybe?

fun dataEmissions() : Observable<YourData>()

and

fun executeNetworkRequest(params: Params)

(note 2nd method returns void).

Hi all, If I use

Completable.create {  }

the

CompletableOnSubscribe

becomes null.

Completable.create((CompletableOnSubscribe)null.INSTANCE);

this is the decompiled version. Since it becomes null, anything I put inside create doesn’t work. But if I use

Completable.create(object : CompletableOnSubscribe{

override fun subscribe(e: CompletableEmitter?) {

}

})

like this, then it is working fine.

@elizarov good luck

Yes, you have turned it into machine that ignores next events. You will only get terminal if subject errors or completes or you get error inside flatMap.

there is a lib to show log like a frodo but support in kotlin?

@thomasnield Thanks for taking care of the SAM conversions in RxJava 2 ! 👍 So far RxKotlin it’s our only hope 😉 https://youtrack.jetbrains.com/issue/KT-14984

@bdeg Of course when using

vararg

all the elements will have to be of the same type (e.g.

Observable<String>

). So if your form has various types, this might me a problem. Maybe it would be better to use something like

Observable.combineLatest()

, which is parametrized (generics) and can handle up to 9 different Observables?

@peasee my book tries to make learning RxJava 2.0 less steep, shameless plug : ) https://www.packtpub.com/application-development/learning-rxjava

Wow thank you, I badly misunderstood that!

Hi guys, does this logic makes sense for you? Or is there a better way of doing this?

why do you subscribe and then do nothing with it?

"Learning RxJava" is now only $10, get it while you can. https://www.packtpub.com/application-development/learning-rxjava

Hello everyone, I've posted a question on stackoverflow around Flowable, Rx, Kotlin, Retrofit2. Thanks to take a look if you can 👍 https://stackoverflow.com/questions/45441074/multiple-retrofit2-requests-using-flowable-in-kotlin

What Dan uses

.concat

for is offline sync, so it depends on heavily what you meant on local observable. Basically he concat the 3 datasource and take the first available. So if you don’t have in the upper layers then you go deeper to the more expensive ones and update the upper ones. answering you question i would go with both of them, take local or network with the most uptodate data, but on the network call just update the local:

fun getDistinctUsers() = Observable
        .concat(local, network.doOnNext{ data -> saveToLocal(data)})
        .first {data -> data.synced }
        .filter(SomeAlgorithm::distinct)

Well, It looks interesting, what exactly does it do?

this is not allowed in case of canonical MVP also i’m use Moxy library for MVP (it’s awesome lib) and Moxy crashes on compile with view method returning non-void value

Hey guys, does anyone have problems with Kotlin and Rx when building the app. I’m using Kotlin’s Boolean type as the generic type : error: unexpected type private final io.reactivex.SingleObserver<boolean> addTripObserver() { ^ required: reference found: boolean java.lang.IllegalStateException: failed to analyze: org.jetbrains.kotlin.kapt3.diagnostic.KaptError: Error while annotation processing and it fails with Java

Gonna cross-post this here - let me know if it's off topic and I'll delete it. Hey guys - i feel like a dope asking this, but I cannot for the life of me figure out how to get the autoformatter in Android Studio to properly handle multiline method calls. So for example, I have the following code:

Observable.just("Foo")
            .map { "Bar" }
            .filter { it == "Baz" }
            .doOnNext { print("Bat") }
            .subscribe { print(it) }

if I try to autoformat it, it puts all the function calls on one line - i.e. it becomes this:

Observable.just("Foo").map { "Bar" }.filter { it == "Baz" }.doOnNext { print("Bat") }.subscribe { print(it) }

What option do I need to change in the kotlin code styles to keep the newlines?

Hi can somebody help me with this error message

Error:(114, 36) None of the following functions can be called with the arguments supplied:
@CheckReturnValue @SchedulerSupport public final fun <T1 : Any!, T2 : Any!, R : Any!> combineLatest(p0: ((Observer<in String!>) -> Unit)!, p1: ((Observer<in String!>) -> Unit)!, p2: ((String, String) -> Boolean)!): Observable<Boolean!>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public final fun <T : Any!, R : Any!> combineLatest(p0: ((Array<(out) Any!>) -> ???)!, p1: Int, p2: Array<(out) ObservableSource<out (???..???)>!>!): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public open fun <T1 : Any!, T2 : Any!, R : Any!> combineLatest(p0: ObservableSource<out (???..???)>!, p1: ObservableSource<out (???..???)>!, p2: BiFunction<in (???..???), in (???..???), out (???..???)>!): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public open fun <T : Any!, R : Any!> combineLatest(p0: Function<in Array<(out) Any!>!, out (???..???)>!, p1: Int, vararg p2: ObservableSource<out (???..???)>!): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public final fun <T : Any!, R : Any!> combineLatest(p0: Array<(out) ObservableSource<out (???..???)>!>!, p1: ((Array<(out) Any!>) -> ???)!, p2: Int): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public open fun <T : Any!, R : Any!> combineLatest(p0: Array<(out) ObservableSource<out (???..???)>!>!, p1: Function<in Array<(out) Any!>!, out (???..???)>!, p2: Int): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public final fun <T : Any!, R : Any!> combineLatest(p0: (Mutable)Iterable<ObservableSource<out (???..???)>!>!, p1: ((Array<(out) Any!>) -> ???)!, p2: Int): Observable<(???..???)>! defined in io.reactivex.Observable
@CheckReturnValue @SchedulerSupport public open fun <T : Any!, R : Any!> combineLatest(p0: (Mutable)Iterable<ObservableSource<out (???..???)>!>!, p1: Function<in Array<(out) Any!>!, out (???..???)>!, p2: Int): Observable<(???..???)>! defined in io.reactivex.Observable

code sample:

val usernameObservable = RxTextView.textChanges(et_username)
			.map { it -> Constants.emailPattern.matcher(it).matches() }
			.distinctUntilChanged()
			.subscribe()

		val passwordObservable = RxTextView.textChanges(et_password)
			.map { it -> it.isNotEmpty()}
			.distinctUntilChanged()
			.subscribe()

		val signInEnabledCondition = BiFunction({ username: CharSequence, password: CharSequence ->
			username.isNotEmpty() && password.isNotEmpty()
		})

		val isSignInEnabled = Observable.combineLatest(usernameObservable, passwordObservable, signInEnabledCondition)

		isSignInEnabled.distinctUntilChanged().subscribe { enabled: Boolean -> bt_sign_in.isEnabled = enabled }

i built one: https://github.com/JakeWharton/Reagent

The greatest FAQ on Reagent

hm, I think it’s valuable to rewrite RxJava in pure Kotlin so you could reuse same business logic on JVM, JS and Native, but I don’t understand desire to couple implementation to coroutines, rx removes need in coroutines, it’s like rewriting Rx on top of

AsyncTask

one might speculate that a large portion of custom operators people write can exists as combinations of existing ones wrapped up inside of an extension method anyway?