Implement operators

[broadwaylamb]

Mapping Elements

• map — Add map operator #9
• tryMap — Implement TryMap #15
• flatMap — FlatMap #45
• mapError — Add map error #23
• replaceNil — Implements replaceNil function #24
• scan — Implement Scan/TryScan and convert Map/TryMap to use common base class. #49, Cherry-pick Scan and TryScan #83
• tryScan — Implement Scan/TryScan and convert Map/TryMap to use common base class. #49, Cherry-pick Scan and TryScan #83
• setFailureType — Implement Publishers.SetFailureType #28

Filtering Elements

• filter — Implement Filter/TryFilter #22
• tryFilter — Implement Filter/TryFilter #22
• compactMap — Implement CompactMap #32
• tryCompactMap — Implement CompactMap #32
• removeDuplicates — Implement all filter-like operators #89
• tryRemoveDuplicates — Implement all filter-like operators #89
• replaceEmpty — Implement Publishers.ReplaceEmpty #122
• replaceError — ReplaceError implementation #50

Reducing Elements

• collect — Implement all reduce-like operators #76
• collect(_:) — Implement Publishers.CollectByCount #137
• collect(_:options:)
• ignoreOutput — Implement IgnoreOutput #44
• reduce — Implement all reduce-like operators #76
• tryReduce — Implement all reduce-like operators #76

Applying Mathematical Operations on Elements

• count — Adds count implementation and tests #20
• max — Implement all reduce-like operators #76
• max(by:) — Implement all reduce-like operators #76
• tryMax(by:) — Implement all reduce-like operators #76
• min — Implement all reduce-like operators #76
• min(by:) — Implement all reduce-like operators #76
• tryMin(by:) — Implement all reduce-like operators #76

Applying Matching Criteria to Elements

• contains — Implement all reduce-like operators #76
• contains(where:) — Implement all reduce-like operators #76
• tryContains(where:) — Implement all reduce-like operators #76
• allSatisfy — Implement all reduce-like operators #76
• tryAllSatisfy — Implement all reduce-like operators #76

Applying Sequence Operations to Elements

• drop(untilOutputFrom:) — Implement Publishers.DropUntilOutput #136
• drop(while:)
• dropFirst — Implement Publishers.Drop #70
• tryDrop(while:)
• append — Implement Publishers.Concatenate #90
• prepend — Implement Publishers.Concatenate #90
• prefix — Implement Publishers.Output #91
• prefix(while:) — Implement all filter-like operators #89
• tryPrefix(while:) — Implement all filter-like operators #89
• prefix(untilOutputFrom:) — Implement PrefixUntilOutput #206

Selecting Specific Elements

• first — First where #29
• first(where:) — First where #29
• tryFirst(where:) — First where #29
• last — Implement all reduce-like operators #76
• last(where:) — Implement all reduce-like operators #76
• tryLast(where:) — Implement all reduce-like operators #76
• output(at:) — Implement Publishers.Output #91
• output(in:) — Implement Publishers.Output #91

Combining Elements from Multiple Publishers

• combineLatest — Implement CombineLatest #119
• merge — Publishers.Merge #72
• zip — Zip implementation #51, Add Zip implementation #109, Implement zip operator  #222

Handling Errors

• assertNoFailure — Implement Publishers.AssertNoFailure #138
• catch — Implement Publishers.Catch and Publishers.TryCatch #140
• tryCatch — Implement Publishers.Catch and Publishers.TryCatch #140
• retry(_:) — Implement Publishers.Retry #178

Adapting Publisher Types

• switchToLatest — Implement Publishers.SwitchToLatest #142

Controlling Timing

• measureInterval — Implement MeasureInterval #117
• debounce — Implement Debounce #133
• delay — Implement Delay #114
• throttle — Add Publishers.Throttle implementation #195
• timeout — Implement Publishers.Timeout #164

Creating Reference-type Publishers

• share — Implement Publishers.Autoconnect, Publishers.Share #60

Encoding and Decoding

• decode — Get initial pass of working Decode publisher #8
• encode — Get initial pass of working Decode publisher #8

Identifying Properties with Key Paths

• map(_ keyPath: KeyPath) — Use GYB tool to implement MapKeyPath #71

Working with Multiple Subscribers

• multicast
• multicast(subject:)

Connecting Automatically

• autoconnect — Implement Publishers.Autoconnect, Publishers.Share #60

Buffering Elements:

• buffer — Implement Publishers.Buffer #143

Performing Type-Erasure

• eraseToAnyPublisher — Add eraseToAnyPublisher() method #59

Specifying Schedulers

• subscribe(on:options:) — Implement SubscribeOn #116
• receive(on:options:) — Implement ReceiveOn #115

Adding Explicit Connectability:

• makeConnectable — Implement Publishers.MakeConnectable #61

Connecting Simple Subscribers:

• assign
• sink

Debugging

• breakpoint — Implement Publishers.Breakpoint and Publishers.HandleEvents #118
• breakpointOnError — Implement Publishers.Breakpoint and Publishers.HandleEvents #118
• handleEvents — Implement Publishers.Breakpoint and Publishers.HandleEvents #118
• print

[zdnk]

Any ETA on combineLatest, merge, zip and catch (or v1) as those are super essential for OpenCombine to be usable instead of RxSwift?

[broadwaylamb]

@zdnk I’m quite busy with my job right now, so I didn’t have time to finish them. I can’t give you any estimation, but I’ll do my best to complete them before summer. Thank you for you interest.

[MaxDesiatov]

I would be happy to help to move this forward and hope I can complete some of these operators myself, those few listed are essential to my use as well. #109 with zip with full test coverage is ready for review, so maybe @broadwaylamb you could do just a review of it in the meantime?

[otaviocc]

Hi folks, what's the status of the last two operators, combineLatest and merge? Our product requires shipping to iOS and macOS that don't support Combine yet, and we're currently using OpenCombine. Is there anything we could do to finish the implementation and have these operators released?

Thank you.

cc: @broadwaylamb

[MaxDesiatov]

The status is publicly visible in this issue and linked PRs. They are unfinished and all contributions are very welcome as usual.