Missing .merge and .throttle

[doronkatz]

Hi folks,

So I have the following:

public func mergedMovies(ids movieIDs: [String]) -> AnyPublisher<[Movie], APIError>{
        let movieIDs = Array(movieIDs.prefix(20))
        
        precondition(!movieIDs.isEmpty)

        let initialPublisher = movie(id: movieIDs[0])
        let remainder = Array(movieIDs.dropFirst())

        #if canImport(Combine)
        return remainder.reduce(initialPublisher) { combined, id in
          return combined
            .merge(with: movie(id: id))
            .eraseToAnyPublisher()
        }
        #else
        return remainder.reduce(initialPublisher) { combined, id in
          return combined
            .merge(with: movie(id: id))
            .eraseToAnyPublisher()
        }
        #endif

    }

I am getting two errors:

value of type 'Any' has no member 'eraseToAnyPublisher'
            .eraseToAnyPublisher()

and,

value of type 'AnyPublisher<[Movie], APIError>' has no member 'merge'
            .merge(with: movie(id: id))

Not sure where ocombine should reside to resolve that, if that is the fix.

Thanks

[broadwaylamb]

Hi!

The reason is that merge and throttle are not implemented yet. merge is being worked on in #72.

[doronkatz]

Got it thanks

[andybest]

Hi, I wondered if there has been any progress made on this?

Thanks :)

[broadwaylamb]

Hi, I wondered if there has been any progress made on this?

Thanks :)

Hi. Nope, I’ve been really busy lately.

[maximkrouk]

Hi, I also wondered if there has been any progress made on this?

I'd like to implement ComposableArchitecture using OpenCombine, but is probably impossible without merge publishers 🙂

Thanks :)

[broadwaylamb]

Nope, no progress. I hope I'll find some time in the coming months, but no promises.

[maximkrouk]

Btw it is implemented in CombineX, maybe this may help
Merge
MergeMany

[broadwaylamb]

Unfortunately, the implementation is not that easy, there are many corner cases. I am pretty certain that the one that you refer to doesn’t handle them all, and is not tested very well.

[maximkrouk]

Any updates? 🙂

[broadwaylamb]

Nope. Doing my best, sorry.

[Degtyarserg]

Hi, I wondered if there has been any progress made on this?

Thanks 😉

[MaxDesiatov]

No updates on this, but all contributions that help us in the implementation are very welcome.