How do you use rx with coroutines? All libs are proof of concept for now,...?

The best presentation about Rx I’ve seen was in Polish…

@adams2 i would expect unsubscribing a connected observable would disconnect but i havent tested that at all

Hello everyone, I'm using RxSwift in my iOS app and now I want to use RxKotlin in my Android app, but one question, with RxSwift you can create a

Variable

to access to the current value (

myVar.value

) and if you want you can create an observable (

myVar.toObservable

). There is a way to do that with RxKotlin ?

I mean if observable1 emitted an item, then received another and is in a delay stage, and at this point observable2 click hits => using

withLatestFrom

would pick a previous item from observable1 which is not what needed

I discovered this - https://github.com/JakeWharton/RxReplayingShare. Seems like it works better than connectable observables for my usecase (see snippet), without actually using connectableobservable

What’s the reason for Wrapping an Observable in another Observable?

I want to get all bytes and merge them together on a ByteArray. All the bytes are organized in such way: The first, m bytes that can be computed to fetch the amount of remaining n bytes

Hi guys, I don’t know what I doing wrong but my next is never call inside the subscribe

rx.Observable.merge(
        events.map{
               eventbus.rxSend(....).toObservalbe()
       }
}.subscribe(next,error)

This message was deleted.

Guys, how would you recommend handling errors on :android: when my scenario is: • subscribe to text changes from search field (with

RxTextView.textChanges(customer_phone_number)

) • debounce queries (every 1second) • show progressBar • execute retrofit call:

apiServices.getMemberDetails(it)

• show membership details on success with

showMemberDetails(it.membership)

• keep waiting for query updates if nothing was found and HttpException: HTTP 400 happened. When HTTP failure happens, my subscription to query updates is lost. What’s correct approach for such scenario?

Think of the different shapes your network response can take, and then map each shape to a member of a sealed class. For example:

sealed class Response {
    data class Success(data: Data): Response()
    data class Error(code: Int, msg: String): Response()
}

Then, when you perform your retrofit action, you can map whatever happens to the appropriate response. The trick is to make sure an error never really enters the stream to begin with (as I believe it gets trickier since as soon as you send an error your original stream is going to terminate)

@viliusk you can compose your stream to deal with the networking error as @alex.hart suggested but you shouldn't be finishing your upstream on networking error basically because what you want keep listening to your stream until your view is destroyed

So I'm kind of new to Rx. Can someone go in depth on the differences between

subscribeOn

and

observeOn

? From what I understand subscribeOn defines where the data is originally emitted from and each subsequent observeOn sends those emissions to different threads?

As in the first one “wins”

My book "Learning RxJava" is on sale for $10. Happy Black Friday everyone. https://www.packtpub.com/application-development/learning-rxjava

But even then, the logout works if I don’t go to CheckInClientActivity but if I go there and return to the home activity where the logout button resides, then the logout doesn’t work (nothing happens really.. as if there was no action to confirming logout through the dialog)

Regarding your question, I’ll take a look into these then, but I saw on a medium tutorial the guy inserting/deleting using

Single.fromCallable

and then I sticked up with it

only the steps after parallel will be parallelized

guys whats the best way to start a flowable after a single completes?

Hey guys, do how did you all get started with RxJava/RxKotlin? I'm relatively new to the whole thing and sometimes have trouble wrapping my head around what's going on. I've got a pretty JS heavy background and found that reading the RxJS docs was actually pretty helpful for understanding overarching concepts, but I'm working on a Kotlin Android project. The RxJava documentation is a bit confusing to me so I'm hoping for something more like a guide or tutorial.

Hi! I have a bunch of `Maybe`'s and I'd like to log when some of them complete without emitting an item. Is this possible somehow? I need a variant of

doOnComplete()

which is invoked only when Maybe is empty...

Is there a way to transform an error before onError() is called on my observer? I'm imagining something like

map

, but where

map

will transform a success result before

onComplete(successResult)

is called, this function would transform an error before

onError(error)

is called

I thought per default you observe on the Thread where you subscribe, but does the first function work, if the second doesn't?

if I add import io.reactivex.functions.Function3 explicitly the error goes away

I did a sample project here, https://github.com/sanogueralorenzo/TestConcatIssue/blob/master/app/src/main/java/com/sanogueralorenzo/testconcatissue/MainActivity.kt even if you use Single.just for the first one you are still able to reproduce the issue sometimes opening the app in airplane mode