gistfile1.java

photos.flatMap(it -> Observable.from(it))
                .delay(1, TimeUnit.SECONDS)
                .subscribeOn(AndroidSchedulers.mainThread())
    
                .flatMap(it -> {
                    view.pictureUploadProgress(it.getPictureType().name()); //to jest ustawienie widoku że wysyłam it element
                    client.uploadDriverPicture(reservationId, pictureInput) //to jest observable który wykonuje potem zapytanie i zwraca response
                    .subscribeOn(Schedulers.io()) // na tym wątku muszę wykonać zapytanie sieciowe 
                    .observeOn(AndroidSchedulers.main()) //na tym wątku mogę robić update widoku, ale nie chcę tego robić tutaj
                    .doOnNext(response -> {})
                    .doOnError(e -> Crashlytics.logException(e)))
                
                .doOnError(e -> view.syncError())
                .doOnCompleted(() -> view.customerPicturesUploaded()) //tutaj ustawiam info że wysłałem już wszystkie zdjęcia
.subscribe();