Hmm. I'll give it a try. Thanks Jake!

i kinda wish flatMap behaved like concatMap by default and you had to use something like mergeMap to get the interleaved behavior

I have an old project which follow the clean architecture repo made by Fernand, the challenge now is to refactor the old retry logic and make it more Rx friendly, but the problem that there's a lot of old code handled in the observer onError, is there anyway to use retryWhen with using onError in the observer

Not entirely show how to ask this question, but had trouble searching for it on StackOverflow so thought I'd try here. What is the best way to always perform a step for certain types of Observables. For example, let's say you had a series of Observables that were performing REST calls, and on their response you wanted to do some basic data validation. Is it better to subclass Observable, or to create a new Observable and just manually chain that after the REST observables?

is there anyway to use groupBy to put one emitted object into multiple groups?

I have FooBarViewModel and QuaxBarViewModel and the BarViewModel base class has a barObservable, to which both children need to add their stuff

obviously not compiler level

Is pinky swear enough?

simple solution might be to add

abstract fun subcsribeToBarObservable

, which gets called by the base class

it’s not forced, but it’s a strong indicator

If you can think of a way to force it I’d love to know as well, because I’ve run into exactly this issue as well 😅

Im trying to hackaround with publish().autoConnect(); sometimes works, sometimes doesnt

afaik that should make the observable hot, so it should not care about subscribers and finish its job, (and propagate results or error to them if there are any) right?

but then if error happens, it crashes on this

ObservablePublish

        @Override
        public void onError(Throwable e) {
            current.compareAndSet(this, null);
            InnerDisposable<T>[] a = observers.getAndSet(TERMINATED);
            if (a.length != 0) {
                for (InnerDisposable<T> inner : a) {
                    inner.child.onError(e);
                }
            } else {
                RxJavaPlugins.onError(e);  <-----
            }
        }

and overriding globally RxJavaPlugins.onError(e) is not an option unless I can do it per observable;

Coming soon to Arrow, Observable/Flowable/Single constructor for suspend functions!

Anyone faced unresolved reference with RXKotlin on Android studio 3.4?

Hey there. Tried searching around for it but wasn't able to find anything. Is there a simple way to use

share()

but when a new observable subscribes, emit whatever the last item was?

share is just publish.refcount

so make it replay.refCount

or something like that I dont remember from head but its trivial

that only replays when the count drops to 0 and back to 1

sounds like you want https://github.com/JakeWharton/RxReplayingShare

well, how about you switch them?

im aware of yoir library but my thing works too, was unsure why you made it

hold on ill check my extensions

then refCount stops working

i made it because it's not possible to do what @nic is asking using the built-in operators

Thanks @jw!

hm I seem to have used the first thing I menfionsd