RxJava - Google Groups (original) (raw)
0 selected
Kamil Demecki, aber...@gmail.com3
10/22/24
Unbounded backpressure in FlowableThanks! I posted it here. On Friday 18 October 2024 at 21:21:45 UTC+2 aber...@gmail.com wrote: Could
unread,
Unbounded backpressure in FlowableThanks! I posted it here. On Friday 18 October 2024 at 21:21:45 UTC+2 aber...@gmail.com wrote: Could
10/22/24
Jadefalke
2/11/22
RXJava emmit from asynchronous sourceHello, not sure if this is the right place to ask, but I was wondering how you could asynchronously
unread,
RXJava emmit from asynchronous sourceHello, not sure if this is the right place to ask, but I was wondering how you could asynchronously
2/11/22
Scorpio The Dark, Dávid Karnok2
8/31/21
Could not deliver value due to lack of requests when .onBackpressureBuffer presentHi. As I mentioned in the Gitter.im thread, the exception should not happen unless something else is
unread,
Could not deliver value due to lack of requests when .onBackpressureBuffer presentHi. As I mentioned in the Gitter.im thread, the exception should not happen unless something else is
8/31/21
Rotem Kadosh
7/29/21
android 12 supportwith the upcoming release of Android 12, should users change or update version to support it?
unread,
android 12 supportwith the upcoming release of Android 12, should users change or update version to support it?
7/29/21
Eva Thil
5/19/21
Please help me by partaking in my thesis studyHi I am writing an undergraduate theses at Mid Sweden University which is investigating the
unread,
Please help me by partaking in my thesis studyHi I am writing an undergraduate theses at Mid Sweden University which is investigating the
5/19/21
Gregory Guthrie, Dávid Karnok10
5/16/21
Beginner issues...While I recognize that Rx provides a richer set of features and capabilities, for something simple
unread,
Beginner issues...While I recognize that Rx provides a richer set of features and capabilities, for something simple
5/16/21
Ujjwal Acharya, Dávid Karnok8
4/13/21
Rxjava2 hash based rail assignment logicI figured out that this doesnot work since each events that is passed on to the rail is going to be a
unread,
Rxjava2 hash based rail assignment logicI figured out that this doesnot work since each events that is passed on to the rail is going to be a
4/13/21
Brahian VT
4/11/21
How interact between PublishSubject and PublishProcessor to simulate deliveries?How interact between PublishSubject and PublishProcessor to simulate deliveries? I have this problem:
unread,
How interact between PublishSubject and PublishProcessor to simulate deliveries?How interact between PublishSubject and PublishProcessor to simulate deliveries? I have this problem:
4/11/21
Tan, J.
3/2/21
Invitation to participate in a survey about RxJavaDear RxJava contributor, We are doing research on understanding how developers manage a special kind
unread,
Invitation to participate in a survey about RxJavaDear RxJava contributor, We are doing research on understanding how developers manage a special kind
3/2/21
rajan sadasivan, Dávid Karnok3
2/21/21
TimeoutException thrown on light load test with rxjava 1 and couchbase java sdkHI David, I have it as 3000 milli seconds in the configuration. Not 3 units, but 3000. thanks for
unread,
TimeoutException thrown on light load test with rxjava 1 and couchbase java sdkHI David, I have it as 3000 milli seconds in the configuration. Not 3 units, but 3000. thanks for
2/21/21
malibu666
8/9/20
Re: my flatMap only accepts String as input; why?Never mind, from what I read the .create(new Observable.OnSubscribe( may be redundant but shouldn
unread,
Re: my flatMap only accepts String as input; why?Never mind, from what I read the .create(new Observable.OnSubscribe( may be redundant but shouldn
8/9/20
A.B
7/3/20
Rxjs-Javascript: How to catch the event of crossing the finish line by a running spriteHi guys, below is the code of a game: a sprite moving along a straight line by pressing on the left
unread,
Rxjs-Javascript: How to catch the event of crossing the finish line by a running spriteHi guys, below is the code of a game: a sprite moving along a straight line by pressing on the left
7/3/20
philippe m, George Campbell2
6/28/20
Rx Java and concurencyTo learn more about Rx on Android look to https://github.com/ReactiveX/RxAndroid/ and probably
unread,
Rx Java and concurencyTo learn more about Rx on Android look to https://github.com/ReactiveX/RxAndroid/ and probably
6/28/20
David Karr, … Justin Breitfeller6
5/12/20
How to ensure that a set of parallel operations are all complete?David, I think you will find that reading a book is really the best way to understand the ins and
unread,
How to ensure that a set of parallel operations are all complete?David, I think you will find that reading a book is really the best way to understand the ins and
5/12/20
SomeGuy OnTheInternet, George Campbell2
4/10/20
Is there a cleaner way to adapt a standard observer/listener service using RxJava2?The second and third argument aren't adding any value. Using is more about wrapping the life
unread,
Is there a cleaner way to adapt a standard observer/listener service using RxJava2?The second and third argument aren't adding any value. Using is more about wrapping the life
4/10/20
Christian Vivas
1/17/20
looking for helptrying to resolve a question i just asked in here https://gitter.im/ReactiveX/RxJava please get in to
unread,
looking for helptrying to resolve a question i just asked in here https://gitter.im/ReactiveX/RxJava please get in to
1/17/20
Daniele Segato, Mohammed Rampurawala2
11/24/19
How to handle shared refreshable / paginated observable properly with RxJava?Do you have a reference to this code on Github or somewhere? Because I am also trying to implement
unread,
How to handle shared refreshable / paginated observable properly with RxJava?Do you have a reference to this code on Github or somewhere? Because I am also trying to implement
11/24/19
avi maslati, Dávid Karnok3
9/15/19
Question about RxJava threading behaviorThanks for making it clear On Sunday, September 15, 2019 at 4:08:47 PM UTC+3, Dávid Karnok wrote: Hi.
unread,
Question about RxJava threading behaviorThanks for making it clear On Sunday, September 15, 2019 at 4:08:47 PM UTC+3, Dávid Karnok wrote: Hi.
9/15/19
Tanya Sharma
8/24/19
Netflix saved $1 billion in 2017Checkout this super interesting post https://www.facebook.com/knowledgco/photos/a.205072903477620/
unread,
Netflix saved $1 billion in 2017Checkout this super interesting post https://www.facebook.com/knowledgco/photos/a.205072903477620/
8/24/19
Brais Gabín Moreira, Justin Breitfeller6
8/23/19
Ways to don't lose a frame with observeOnEither of my solutions would handle your problem. As far as the first approach I mentioned, you
unread,
Ways to don't lose a frame with observeOnEither of my solutions would handle your problem. As far as the first approach I mentioned, you
8/23/19
James Tobin
8/20/19
Lead architectHello, I'm looking to hire in London a developer that can fulfil a lead architect position in a
unread,
Lead architectHello, I'm looking to hire in London a developer that can fulfil a lead architect position in a
8/20/19
Shvalbo, Dávid Karnok5
5/30/19
Single doesn't expose blockingGet with timeoutOk, I need to get more familiar with using this class. so why it makes sense to have it in
unread,
Single doesn't expose blockingGet with timeoutOk, I need to get more familiar with using this class. so why it makes sense to have it in
5/30/19
Gino Miceli2
5/18/19
Simpler way to Observable.switchMap(Completable) w/error handling?Note: In my example I meant to include a predicate in onErrorComplete() or a call to doOnError() to
unread,
Simpler way to Observable.switchMap(Completable) w/error handling?Note: In my example I meant to include a predicate in onErrorComplete() or a call to doOnError() to
5/18/19
Josef Pfleger, Dávid Karnok3
4/29/19
concatMapEagerSingle?I see, thank you. We've been using the toXXX conversions anyways, I was just wondering why some
unread,
concatMapEagerSingle?I see, thank you. We've been using the toXXX conversions anyways, I was just wondering why some
4/29/19
Igor Zubchenok
3/19/19
Flowable.concatMapEagerDelayError doesn't work as expected (v2.2.6)Hello I use Flowable.concatMapEagerDelayError with concurrency=2 if first item is slow, second is
unread,
Flowable.concatMapEagerDelayError doesn't work as expected (v2.2.6)Hello I use Flowable.concatMapEagerDelayError with concurrency=2 if first item is slow, second is
3/19/19
Kevin GALLARDO, Dávid Karnok5
1/17/19
Timeout for the entire sequence and not individual itemsHey Dávid, I see, that's a pretty good solution, thanks a lot! Le jeudi 17 janvier 2019 12:47:59
unread,
Timeout for the entire sequence and not individual itemsHey Dávid, I see, that's a pretty good solution, thanks a lot! Le jeudi 17 janvier 2019 12:47:59
1/17/19
Johannes Schneider
1/15/19
RxJava2: parallel(): Want to know if at least one rail completes (conversion to Maybe)Hi guys, I want to download a file from several possible locations. Each location has three possible
unread,
RxJava2: parallel(): Want to know if at least one rail completes (conversion to Maybe)Hi guys, I want to download a file from several possible locations. Each location has three possible
1/15/19
秋天, Afluy2
12/19/18
how to continue processing when subscriber throws an exception in rxjava?Observable.fromCallable(new Callable() { @Override public DownloadResult call() throws
unread,
how to continue processing when subscriber throws an exception in rxjava?Observable.fromCallable(new Callable() { @Override public DownloadResult call() throws
12/19/18
John Sanda, … Hélder Sousa4
10/25/18
Is window operator right for this?Hi John, Did you find a solution for your use case? I have a similar one and I can't find a
unread,
Is window operator right for this?Hi John, Did you find a solution for your use case? I have a similar one and I can't find a
10/25/18
ViveK Panchal
9/28/18
Hii Can anyone tell me how to Write to internal storage and Read via Rx java ??as I am a beginner I wanted to save multiple files fast using Rx java and read them and show to
unread,
Hii Can anyone tell me how to Write to internal storage and Read via Rx java ??as I am a beginner I wanted to save multiple files fast using Rx java and read them and show to
9/28/18