servicetalk / PR 2690
Add Publisher.zip
apple/servicetalk#2690 openmixed
+2872/−19lines
19files
4comments
2023-09-08opened
-merged
What it touches
test: 15 main: 4
Modules: servicetalk-concurrent-reactivestreams (11), servicetalk-concurrent-api (8)
Architectural impact (arcade-agent diff_impact)
3files mapped to the graph
186entities in those files
Concurrentcomponents
4143entities within 3 hops downstream
Most depended-upon changed entities
| Entity | Dependents |
|---|---|
io.servicetalk.concurrent.api.Publisher | 1325 |
io.servicetalk.concurrent.api.Publisher.from | 291 |
io.servicetalk.concurrent.api.Publisher.fromIterable | 177 |
io.servicetalk.concurrent.api.Publisher.fromInputStream | 97 |
io.servicetalk.concurrent.api.Publisher.defer | 92 |
io.servicetalk.concurrent.api.Publisher.empty | 89 |
io.servicetalk.concurrent.api.Publisher.failed | 67 |
io.servicetalk.concurrent.api.Publisher.Publisher | 35 |
Computed against the current default branch, not the PR base commit; files renamed or deleted since then are unmatched. Downstream counts are a reverse-dependency closure to depth 3 and over-approximate real blast radius.
Files
| main | servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Publisher.java |
| main | servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/PublisherZipper.java |
| main | servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java |
| main | servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/SingleZipper.java |
| test | servicetalk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/PublisherZip3Test.java |
| test | servicetalk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/PublisherZip4Test.java |
| test | servicetalk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/PublisherZip5Test.java |
| test | servicetalk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/PublisherZipWithTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/AbstractPublisherZipTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherSwitchMapDelayErrorTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherSwitchMapTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZip3DelayErrorTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZip3TckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZip4DelayErrorTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZip4TckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZip5DelayErrorTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZip5TckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZipWithDelayErrorTckTest.java |
| test | servicetalk-concurrent-reactivestreams/src/test/java/io/servicetalk/concurrent/reactivestreams/tck/PublisherZipWithTckTest.java |