Using zip operator in RxSwift after creating an array of observables

Question

I have a newBid object, that contains some data and images array. I want to upload all images and data to the server and zip those upload observables. If I create separate drivers for data, image1 and image2, I succeed.

But what I want to really do is to not hardcode images since array may contain from 0 to 10 images. I want to create observables array programmatically and zip them.

let dataSaved = saveTaps.withLatestFrom(newBid)
    .flatMapLatest { bid in
        return CustomerManager.shared.bidCreate(bid: bid)
            .trackActivity(activityIndicator)
            .asDriver(onErrorJustReturn: false)
}

let photoSaved0 = saveTaps.withLatestFrom(newBid)
    .flatMapLatest { bid in
        return CustomerManager.shared.bidUploadFile(image: bid.images[0])
            .trackActivity(activityIndicator)
            .asDriver(onErrorJustReturn: false)
}

let photoSaved1 = saveTaps.withLatestFrom(newBid)
    .flatMapLatest { bid in
        return CustomerManager.shared.bidUploadFile(image: bid.images[1])
            .trackActivity(activityIndicator)
            .asDriver(onErrorJustReturn: false)
}

saveCompleted = Driver.zip(dataSaved, photoSaved0, photoSaved1){ return $0 && $1 && $2 }

/*
// 0. Getting array of images from newBid
let images = newBid.map { bid in
    return bid.images
}

// 1. Creating array of upload drivers from array of images
let imageUploads = images.map { (images: [UIImage]) -> [Driver<Bool>] in
    var temp = [Driver<Bool>]()
    return temp
}

// 2. Zipping array of upload drivers to photoSaved driver
photoSaved = Driver
    .zip(imageUploads) // wait for all image requests to finish
    .subscribe(onNext: { results in
        // here you have every single image in the 'images' array
        results.forEach { print($0) }
    })
    .disposed(by: disposeBag)*/

In the commented section if I try to zip imageUploads, I get error:

Argument type 'SharedSequence<DriverSharingStrategy, [SharedSequence<DriverSharingStrategy, Bool>]>' does not conform to expected type 'Collection'

Daniel T. · Accepted Answer · 2018-08-19 17:48:45Z

2

How about something like this?

let saves = saveTaps.withLatestFrom(newBid)
    .flatMapLatest { (bid: Bid) -> Observable<[Bool]> in
        let dataSaved = CustomerManager.shared.bidCreate(bid: bid)
            .catchErrorJustReturn(false)

        let photosSaved = bid.images.map {
            CustomerManager.shared.bidUploadFile(image: $0, bidID: bid.id)
                .catchErrorJustReturn(false)
        }

        return Observable.zip([dataSaved] + photosSaved)
            .trackActivity(activityIndicator)
    }
    .asDriver(onErrorJustReturn: []) // remove this line if you want an Observable<[Bool]>.

edited Aug 19, 2018 at 17:48

answered Aug 16, 2018 at 11:35

Daniel T.

34.1k6 gold badges55 silver badges75 bronze badges

Sign up to request clarification or add additional context in comments.

7 Comments

Denis Kutlubaev Over a year ago

Thanks, I will try.

Daniel T. Over a year ago

As an FYI. The zip operator doesn't upload the images one at a time. It will start all the uploads at the same time and report back when they are all complete.

Denis Kutlubaev Over a year ago

I have an error with this: Cannot convert value of type '(Bid) -> Observable<[Bool]>' to expected argument type '() -> SharedSequence<, _>'

Daniel T. Over a year ago

What do your CustomerManager functions return? I was assuming they returned Observable<Bool>.

Denis Kutlubaev Over a year ago

Yes. It returns Observable<Bool>

|

Denis Kutlubaev · Accepted Answer · 2018-08-19 14:34:32Z

Final solution

let bidID: Driver<Int> = saveTaps.withLatestFrom(newBid)
    .flatMapLatest { bid in
        return CustomerManager.shared.bidCreate(bid: bid)
            .trackActivity(activityIndicator)
            .asDriver(onErrorJustReturn: 0)
}

saveCompleted = Driver.combineLatest(bidID, newBid) { bidID, newBid in
    newBid.uploadedImages.map {
        CustomerManager.shared.bidUploadFile(image: $0, bidID: bidID).asDriver(onErrorJustReturn: false)
    }
    }.flatMap { imageUploads in
        return Driver.zip(imageUploads).trackActivity(activityIndicator).asDriver(onErrorJustReturn: [])
    }.map{ (results:[Bool]) -> Bool in
        return !results.contains(false)
}

It is a combined version of this which is equivalent:

let imageUploads: Driver<[Driver<Bool>]> = Driver.combineLatest(bidID, newBid) { bidID, newBid in
    newBid.uploadedImages.map {
        CustomerManager.shared.bidUploadFile(image: $0, bidID: bidID).asDriver(onErrorJustReturn: false)
    }
}

let photosSaved: Driver<[Bool]> = imageUploads.flatMap { imageUploads in
    return Driver.zip(imageUploads).trackActivity(activityIndicator).asDriver(onErrorJustReturn: [])
}

saveCompleted = photosSaved.map{ (results:[Bool]) -> Bool in
    return !results.contains(false)
}

Collectives™ on Stack Overflow

Using zip operator in RxSwift after creating an array of observables

2 Answers 2

7 Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

7 Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related