Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(concurrentConcatAll): Add custom operator for managing multiple concurrent inner subscriptions but maintaining the output order #26

Open
wants to merge 1 commit into
base: master
Choose a base branch
from

Conversation

zakhenry
Copy link
Collaborator

Closes #22

 concurrent inner subscriptions but maintaining the output order
@@ -7,3 +7,5 @@ export * from './lib/observable-worker.decorator';
export * from './lib/run-worker';
export * from './lib/from-worker';
export * from './lib/from-worker-pool';
// @todo move down to a 'observable-worker/helper' sub module to ensure it is not always bundled
export * from './lib/concurrent-concat-all';
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This needs to happen before merging

@codecov
Copy link

codecov bot commented Aug 12, 2019

Codecov Report

Merging #26 into master will decrease coverage by 70.7%.
The diff coverage is 100%.

Impacted file tree graph

@@             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%) ⬇️
...rojects/observable-webworker/src/lib/run-worker.ts 0% <0%> (-100%) ⬇️
...s/observable-webworker/src/lib/from-worker-pool.ts 0% <0%> (-100%) ⬇️
...e-webworker/src/lib/observable-worker.decorator.ts 0% <0%> (-100%) ⬇️

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update a16ec9b...641af4f. Read the comment docs.

@zakhenry
Copy link
Collaborator Author

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Add helper operator concurrentConcatAll() to allow for ordered output
2 participants