Like RxJS timeout, but only for emissions that are not ignored.
Values that match config.ignore are forwarded immediately and do not affect
timeout state (first/each). Timeout timing only observes non-ignored values.
Example usage:
source$.pipe(
timeoutWithIgnore({
first: 1500,
each: 1000,
with: () => of(null),
ignore: value => value === undefined,
})
)
Like RxJS
timeout, but only for emissions that are not ignored.Values that match
config.ignoreare forwarded immediately and do not affect timeout state (first/each). Timeout timing only observes non-ignored values.Example usage:
source$.pipe( timeoutWithIgnore({ first: 1500, each: 1000, with: () => of(null), ignore: value => value === undefined, }) )