nsk-mironov

public class Main {
    public static void main(String[] args) {
        ContentManager cm = new ContentManager();

        Observable
                .from(cm.getPermalinks(10))
                .flatMap(permalink -> Observable.zip(
                        Observable.<Content>create(subscriber -> cm.getDataByPermalink(permalink, new SubscribingRestCallback(subscriber))),
                        Observable.<Content>create(subscriber -> cm.getStreamByPermalink(permalink, new SubscribingRestCallback(subscriber))),
                        (dataContent, streamUrlContent) -> {

nsk-mironov

final Observable<MyDatum> observable = Observable.interval(10, TimeUnit.SECONDS).flatMap(new Func1<Long, Observable<MyDatum>>() {
    @Override
    public Observable<MyDatum> call(final Long counter) {
        return db.select("SELECT f1,f2 FROM mydata")
                .autoMap(MyDatum.class)
                .doOnNext(new Action1<MyDatum>() {
                    @Override
                    public void call(final MyDatum value) {
                        state.add(value);
                    }

nsk-mironov

public Observable<Response> upload(final Image image) {
    // create new ArrayList in case if image.getChunks() returns immutable collection
    final List<Chunk> chunks = new ArrayList<Chunk>(image.getChunks());

    if (chunks.isEmpty()) {
        return Observable.empty();
    }

    if (chunks.size() == 1) {
        return api.upload(chunks.get(0));