RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
so no need to worry about it inbetween
unpacking tuples in every
map etc.
@fAns1k : What you can do, is do your subscribe logic in the lat
map and use a empty .subscribe() after the flatmap. Might be appropriate to use doOnEach. Perhaps only part of your logic needs to be there. Not my favorite solution but at least it's readable.
and inside onNext i need to have data.getId() [from the first step], that is my current logic
the explanation feels a little funny to me as it seems like whether or not
doOnTerminate is called after a downstream error is at the discretion of the operator
seems a little bit like a leaky abstraction to me, but c'est la vie
Uppss sorry not here :D
hi all, how i can handle empty data inside flatMap, here is my code
private Observable<Invoices> getInvoicesObservable(Invoices invoices) {
return invoices == null || invoices.getInvoices() == null ? Observable.empty()
: Observable.combineLatest(Observable.just(invoices), Observable.from(invoices.getInvoices())
.filter(invoice -> invoice.getStatus() == InvoiceStatus.UNPAID)
.toSortedList(), (Invoices rawInvoice, List<Invoice> invoiceList) -> {
rawInvoice.setInvoices(invoiceList);
return rawInvoice;
});
}combileLatest(..,…, getInvoicesObservable)- and in case with null data it never ends
are there any other interesting open source projects with very active gitter boards?
but i keep either “losing” subscriptions to it somehow or it just dies
is what i’m doing not supposed to work?
@Dorus no effect. Subscription is still lost.
I tihnk i found my problem
Oh good :)
.asObservable()
how do i do
.distinct() but only for consecutive elements?
distinctUntilChanged() ?
Im trying to figure out how to represent the following nested for loops in Rx constructs. Having trouble getting something elegant. What am i missing? here's the pseudo code http://pastebin.com/raw.php?i=G0k9ZR4N
I can give you an example in Java
private static int getLevelFor(String s) {
return s.length();
}
public void forFor() {
List<String> uids = Arrays.asList("A", "BB", "CCCCCC");
Observable.from(uids)
.flatMap(new Func1<String, Observable<String>>() {
@Override
public Observable<String> call(final String s) {
return Observable.range(1, getLevelFor(s))
.map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
return s + "," + integer;
}
});
}
})
.toBlocking()
.forEach(new Action1<Object>() {
@Override
public void call(Object o) {
System.out.println(o);
}
});
}
outputs:
A,1
BB,1
BB,2
CCCCCC,1
CCCCCC,2
CCCCCC,3
CCCCCC,4
CCCCCC,5
CCCCCC,6
(of course String would have to be replaced by a pair or you actual domain object)
(and the toBlocking section is just here so that I can execute this in a standalone main or unit test)