How to use the onErrorResumeNext function from rxjs

setup.js

GitHub: mojaloop/event-stream-processor

81
82
83
84
85
86
87
88
89
90
  flatMap(Observables.TraceObservable.extractContextObservable),
  flatMap(Observables.TraceObservable.cacheSpanContextObservable),
  flatMap(Observables.TraceObservable.findLastSpanObservable),
  flatMap(Observables.TraceObservable.recreateTraceObservable),
  flatMap(Observables.TraceObservable.sendTraceToApmObservable),
  catchError(e => { return Rx.onErrorResumeNext(tracingObservable) }))

tracingObservable.subscribe({
  next: traceId => {
    Logger.debug(`traceId ${traceId} sent to APM`)

10

1

11

+ 27 other calls in file

app.js

GitHub: PacktPublishing/Architecting-Reactive-Angular-Applications-with-Redux-and-NgRx-Video-

69
70
71
72
73
74
75
76
77
78
streamCombined$.subscribe(
  data => console.log('combined data', data),
  err => console.log('combined err', err)
);

const streamCombinedIgnore$ = onErrorResumeNext(
    throwError('error'), // of(1,2,3),
    of (4, 5, 6), 
    of (7, 8, 9)
  )

9

10

5

+ 3 other calls in file

index.js

GitHub: caosbad/api

56
57
58
59
60
61
62
63
64
65
exports.iif = rxjs.iif;
exports.interval = rxjs.interval;
exports.merge = rxjs.merge;
exports.never = rxjs.never;
exports.of = rxjs.of;
exports.onErrorResumeNext = rxjs.onErrorResumeNext;
exports.pairs = rxjs.pairs;
exports.partition = rxjs.partition;
exports.race = rxjs.race;
exports.range = rxjs.range;

299

0

1

architect.js

GitHub: cuongnqph06515/node_modules

46
47
48
49
50
51
52
53
54
55
// Using a share replay because the job might be synchronously sending input, but
// asynchronously listening to it.
operators_1.shareReplay(1));
// Make an inboundBus that completes instead of erroring out.
// We'll merge the errors into the output instead.
const inboundBus = rxjs_1.onErrorResumeNext(inboundBusWithInputValidation);
const output = rxjs_1.from(host.loadBuilder(info)).pipe(operators_1.concatMap(builder => {
    if (builder === null) {
        throw new Error(`Cannot load builder for builderInfo ${JSON.stringify(info, null, 2)}`);
    }

0

0

0

+ 2 other calls in file