How to use the wonka.mergeMap function in wonka
To help you get started, we’ve selected a few wonka examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
FormidableLabs / urql / src / exchanges / subscription.ts View on Github 
return ops$ => {
const sharedOps$ = share(ops$);
const subscriptionResults$ = pipe(
sharedOps$,
filter(isSubscriptionOperation),
mergeMap(operation => {
const { key } = operation;
const teardown$ = pipe(
sharedOps$,
filter(op => op.operationName === 'teardown' && op.key === key)
);
return pipe(
createSubscriptionSource(operation),
takeUntil(teardown$)
);
})
);
const forward$ = pipe(
sharedOps$,
filter(op => !isSubscriptionOperation(op)),return ops$ => {
const sharedOps$ = share(ops$);
const fetchResults$ = pipe(
sharedOps$,
filter(isOperationFetchable),
mergeMap(operation => {
const { key } = operation;
const teardown$ = pipe(
sharedOps$,
filter(op => op.operationName === 'teardown' && op.key === key)
);
return pipe(
createFetchSource(operation),
takeUntil(teardown$)
);
})
);
const forward$ = pipe(
sharedOps$,
filter(op => !isOperationFetchable(op)),wonka
A tiny but capable push & pull stream library for TypeScript and Flow
