observable-webworker
observable-webworker copied to clipboard
feat(concurrentConcatAll): Add custom operator for managing multiple concurrent inner subscriptions but maintaining the output order
Closes #22
Codecov Report
Merging #26 into master will decrease coverage by
70.7%. The diff coverage is100%.
@@ Coverage Diff @@
## master #26 +/- ##
===========================================
- Coverage 100% 29.29% -70.71%
===========================================
Files 5 6 +1
Lines 73 99 +26
Branches 13 18 +5
===========================================
- Hits 73 29 -44
- Misses 0 70 +70
| Impacted Files | Coverage Δ | |
|---|---|---|
| ...ervable-webworker/src/lib/concurrent-concat-all.ts | 100% <100%> (ø) |
|
| ...ojects/observable-webworker/src/lib/from-worker.ts | 0% <0%> (-100%) |
:arrow_down: |
| ...rojects/observable-webworker/src/lib/run-worker.ts | 0% <0%> (-100%) |
:arrow_down: |
| ...s/observable-webworker/src/lib/from-worker-pool.ts | 0% <0%> (-100%) |
:arrow_down: |
| ...e-webworker/src/lib/observable-worker.decorator.ts | 0% <0%> (-100%) |
:arrow_down: |
Continue to review full report at Codecov.
Legend - Click here to learn more
Δ = absolute <relative> (impact),ø = not affected,? = missing dataPowered by Codecov. Last update a16ec9b...641af4f. Read the comment docs.
Looks like the internals of RxJS has moved with v7, and there is now a common merge operator that will make it easier to implement in core.