How to use rxjs

dispatchCentral.js

GitHub: PredictiveMovement/digital-twin

83
84
85
86
87
88
89
90
91
92
    car: cars[i],
    bookings,
  }))
}),
catchError((err) => error('cluster err', err)),
mergeAll(),
filter(({ bookings }) => bookings.length > 0),
tap(({ car, bookings }) =>
  info(
    `Plan ${car.id} (${car.fleet.name}) received ${bookings.length} bookings`

1

16

0

See more examples

cloudStorageDownload.js

GitHub: openforis/sepal

74
75
76
77
78
79
80
81
82
83

const downloadFiles$ = ({files, prefix, downloadDir, deleteAfterDownload}) => {
    return of(files).pipe(
        switchMap(files => of(...files)),
        mergeMap(file => downloadFile$({file, prefix, downloadDir, deleteAfterDownload}), CONCURRENT_FILE_DOWNLOAD),
        scan((currentProgress, fileProgress) => getProgress({
            files,
            currentProgress,
            fileProgress
        }), initialState(files))

45

178

34

See more examples

cloudStorageDownload.js

GitHub: openforis/sepal

117
118
119
120
121
122
123
124
125
126
}

return createDirs$(path.dirname(toFilePath)).pipe(
    switchMap(() =>
        downloadChunk$(0).pipe(
            expand(({end, length}) => {
                let downloaded = isDownloaded({end, length})
                return downloaded ? EMPTY : downloadChunk$(end + 1)
            })
        )

45

178

34

See more examples

index.js

GitHub: PredictiveMovement/digital-twin

89
90
91
92
93
94
95
96
97
98
  })

experiment.bookingUpdates = experiment.dispatchedBookings.pipe(
  mergeMap((booking) => booking.statusEvents),
  catchError((err) => error('bookingUpdates', err)),
  share()
)

experiment.passengerUpdates = experiment.passengers.pipe(
  mergeMap(({ deliveredEvents, pickedUpEvents }) =>

1

16

0

See more examples

index.js

GitHub: alexhscott/team-profile-generator

308
309
310
311
312
313
314
315
316
317
318
319
320
//         answer.engineerEmail,
//         answer.engineerGitHub
//     );


//     team.push(engineer);
//     repeat();
// };




// // Questions for inputting information and adding intern

0

0

0

See more examples

fetchChunk.js

GitHub: lobotomisador/algorithms

10
11
12
13
14
15
16
17
18
19
20
    // tap(e => console.info('after', e)),
    catchError(e => {
        console.error('fn errored', e)
        throw new Error()
    }),
    retry(1),
    )


range(10)
.pipe(

0

0

0

See more examples

events02.js

GitHub: iproduct/course-node-express-react

20
21
22
23
24
25
26
27
28
29
30
31
32




// genrate events of type myEvent


rx.interval(450).pipe(
    rx.take(5)
).forEach(
    i => mee.emit('myEvent', 'Hello event ' + i)
);

12

39

0

See more examples

index.js

GitHub: caosbad/api

21
22
23
24
25
26
27
28
29
30
exports.asap = rxjs.asap;
exports.asapScheduler = rxjs.asapScheduler;
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;
exports.VirtualAction = rxjs.VirtualAction;

299

0

1

See more examples

index.js

GitHub: caosbad/api

20
21
22
23
24
25
26
27
28
29
exports.AsyncSubject = rxjs.AsyncSubject;
exports.asap = rxjs.asap;
exports.asapScheduler = rxjs.asapScheduler;
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;

299

0

1

See more examples

index.js

GitHub: caosbad/api

25
26
27
28
29
30
31
32
33
34
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;
exports.VirtualAction = rxjs.VirtualAction;
exports.Scheduler = rxjs.Scheduler;
exports.Subscription = rxjs.Subscription;
exports.Subscriber = rxjs.Subscriber;
exports.Notification = rxjs.Notification;

299

0

1

See more examples

index.js

GitHub: caosbad/api

38
39
40
41
42
43
44
45
46
47
exports.identity = rxjs.identity;
exports.isObservable = rxjs.isObservable;
exports.ArgumentOutOfRangeError = rxjs.ArgumentOutOfRangeError;
exports.EmptyError = rxjs.EmptyError;
exports.ObjectUnsubscribedError = rxjs.ObjectUnsubscribedError;
exports.UnsubscriptionError = rxjs.UnsubscriptionError;
exports.TimeoutError = rxjs.TimeoutError;
exports.bindCallback = rxjs.bindCallback;
exports.bindNodeCallback = rxjs.bindNodeCallback;
exports.combineLatest = rxjs.combineLatest;

299

0

1

See more examples

index.js

GitHub: caosbad/api

10
11
12
13
14
15
16
17
18
19

const rxjs = require('rxjs');

exports.Observable = rxjs.Observable;
exports.ConnectableObservable = rxjs.ConnectableObservable;
exports.GroupedObservable = rxjs.GroupedObservable;
exports.observable = rxjs.observable;
exports.Subject = rxjs.Subject;
exports.BehaviorSubject = rxjs.BehaviorSubject;
exports.ReplaySubject = rxjs.ReplaySubject;

299

0

1

See more examples

index.js

GitHub: caosbad/api

36
37
38
39
40
41
42
43
44
45
exports.pipe = rxjs.pipe;
exports.noop = rxjs.noop;
exports.identity = rxjs.identity;
exports.isObservable = rxjs.isObservable;
exports.ArgumentOutOfRangeError = rxjs.ArgumentOutOfRangeError;
exports.EmptyError = rxjs.EmptyError;
exports.ObjectUnsubscribedError = rxjs.ObjectUnsubscribedError;
exports.UnsubscriptionError = rxjs.UnsubscriptionError;
exports.TimeoutError = rxjs.TimeoutError;
exports.bindCallback = rxjs.bindCallback;

299

0

1

See more examples

pool.js

GitHub: VEGMQAZ/sepal

22
23
24
25
26
27
28
29
30
31
    mergeMap(instance =>
        timer(maxIdleMilliseconds).pipe(
            takeUntil(lock$.pipe(
                filter(currentInstance => currentInstance === instance)
            )),
            mapTo(instance)
        )
    )
).subscribe({
    next: instance => dispose(instance),

45

0

0

See more examples

index.js

GitHub: caosbad/api

33
34
35
36
37
38
39
40
41
42
exports.Subscriber = rxjs.Subscriber;
exports.Notification = rxjs.Notification;
exports.NotificationKind = rxjs.NotificationKind;
exports.pipe = rxjs.pipe;
exports.noop = rxjs.noop;
exports.identity = rxjs.identity;
exports.isObservable = rxjs.isObservable;
exports.ArgumentOutOfRangeError = rxjs.ArgumentOutOfRangeError;
exports.EmptyError = rxjs.EmptyError;
exports.ObjectUnsubscribedError = rxjs.ObjectUnsubscribedError;

299

0

1

See more examples

index.js

GitHub: caosbad/api

28
29
30
31
32
33
34
35
36
37
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;
exports.VirtualAction = rxjs.VirtualAction;
exports.Scheduler = rxjs.Scheduler;
exports.Subscription = rxjs.Subscription;
exports.Subscriber = rxjs.Subscriber;
exports.Notification = rxjs.Notification;
exports.NotificationKind = rxjs.NotificationKind;
exports.pipe = rxjs.pipe;
exports.noop = rxjs.noop;

299

0

1

See more examples

task.js

GitHub: openforis/sepal

49
50
51
52
53
54
55
56
57
58
            (error || state === FAILED)
                ? throwError(() => new Error(error))
                : of(state)
        ),
        distinctUntilChanged(),
        takeWhile(state => isRunning(state)),
        map(toProgress)
    )

const toProgress = state => {

45

178

34

See more examples

index.js

GitHub: caosbad/api

50
51
52
53
54
55
56
57
58
59
exports.empty = rxjs.empty;
exports.forkJoin = rxjs.forkJoin;
exports.from = rxjs.from;
exports.fromEvent = rxjs.fromEvent;
exports.fromEventPattern = rxjs.fromEventPattern;
exports.generate = rxjs.generate;
exports.iif = rxjs.iif;
exports.interval = rxjs.interval;
exports.merge = rxjs.merge;
exports.never = rxjs.never;

299

0

1

See more examples

index.js

GitHub: caosbad/api

39
40
41
42
43
44
45
46
47
48
exports.isObservable = rxjs.isObservable;
exports.ArgumentOutOfRangeError = rxjs.ArgumentOutOfRangeError;
exports.EmptyError = rxjs.EmptyError;
exports.ObjectUnsubscribedError = rxjs.ObjectUnsubscribedError;
exports.UnsubscriptionError = rxjs.UnsubscriptionError;
exports.TimeoutError = rxjs.TimeoutError;
exports.bindCallback = rxjs.bindCallback;
exports.bindNodeCallback = rxjs.bindNodeCallback;
exports.combineLatest = rxjs.combineLatest;
exports.concat = rxjs.concat;

299

0

1

See more examples

index.js

GitHub: caosbad/api

17
18
19
20
21
22
23
24
25
26
exports.Subject = rxjs.Subject;
exports.BehaviorSubject = rxjs.BehaviorSubject;
exports.ReplaySubject = rxjs.ReplaySubject;
exports.AsyncSubject = rxjs.AsyncSubject;
exports.asap = rxjs.asap;
exports.asapScheduler = rxjs.asapScheduler;
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;

299

0

1

See more examples

index.js

GitHub: caosbad/api

58
59
60
61
62
63
64
65
66
67
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;
exports.throwError = rxjs.throwError;
exports.timer = rxjs.timer;

299

0

1

See more examples

index.js

GitHub: caosbad/api

35
36
37
38
39
40
41
42
43
44
exports.NotificationKind = rxjs.NotificationKind;
exports.pipe = rxjs.pipe;
exports.noop = rxjs.noop;
exports.identity = rxjs.identity;
exports.isObservable = rxjs.isObservable;
exports.ArgumentOutOfRangeError = rxjs.ArgumentOutOfRangeError;
exports.EmptyError = rxjs.EmptyError;
exports.ObjectUnsubscribedError = rxjs.ObjectUnsubscribedError;
exports.UnsubscriptionError = rxjs.UnsubscriptionError;
exports.TimeoutError = rxjs.TimeoutError;

299

0

1

See more examples

index.js

GitHub: caosbad/api

19
20
21
22
23
24
25
26
27
28
exports.ReplaySubject = rxjs.ReplaySubject;
exports.AsyncSubject = rxjs.AsyncSubject;
exports.asap = rxjs.asap;
exports.asapScheduler = rxjs.asapScheduler;
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;

299

0

1

See more examples

index.js

GitHub: caosbad/api

49
50
51
52
53
54
55
56
57
58
exports.defer = rxjs.defer;
exports.empty = rxjs.empty;
exports.forkJoin = rxjs.forkJoin;
exports.from = rxjs.from;
exports.fromEvent = rxjs.fromEvent;
exports.fromEventPattern = rxjs.fromEventPattern;
exports.generate = rxjs.generate;
exports.iif = rxjs.iif;
exports.interval = rxjs.interval;
exports.merge = rxjs.merge;

299

0

1

See more examples

index.js

GitHub: caosbad/api

23
24
25
26
27
28
29
30
31
32
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;
exports.VirtualAction = rxjs.VirtualAction;
exports.Scheduler = rxjs.Scheduler;
exports.Subscription = rxjs.Subscription;

299

0

1

See more examples

index.js

GitHub: caosbad/api

16
17
18
19
20
21
22
23
24
25
exports.observable = rxjs.observable;
exports.Subject = rxjs.Subject;
exports.BehaviorSubject = rxjs.BehaviorSubject;
exports.ReplaySubject = rxjs.ReplaySubject;
exports.AsyncSubject = rxjs.AsyncSubject;
exports.asap = rxjs.asap;
exports.asapScheduler = rxjs.asapScheduler;
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;

299

0

1

See more examples

index.js

GitHub: caosbad/api

24
25
26
27
28
29
30
31
32
33
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;
exports.VirtualAction = rxjs.VirtualAction;
exports.Scheduler = rxjs.Scheduler;
exports.Subscription = rxjs.Subscription;
exports.Subscriber = rxjs.Subscriber;

299

0

1

See more examples

index.js

GitHub: caosbad/api

22
23
24
25
26
27
28
29
30
31
exports.asapScheduler = rxjs.asapScheduler;
exports.async = rxjs.async;
exports.asyncScheduler = rxjs.asyncScheduler;
exports.queue = rxjs.queue;
exports.queueScheduler = rxjs.queueScheduler;
exports.animationFrame = rxjs.animationFrame;
exports.animationFrameScheduler = rxjs.animationFrameScheduler;
exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler;
exports.VirtualAction = rxjs.VirtualAction;
exports.Scheduler = rxjs.Scheduler;

299

0

1

See more examples

index.js

GitHub: caosbad/api

63
64
65
66
67
68
69
70
71
72
exports.partition = rxjs.partition;
exports.race = rxjs.race;
exports.range = rxjs.range;
exports.throwError = rxjs.throwError;
exports.timer = rxjs.timer;
exports.using = rxjs.using;
exports.zip = rxjs.zip;
exports.scheduled = rxjs.scheduled;
exports.EMPTY = rxjs.EMPTY;
exports.NEVER = rxjs.NEVER;

299

0

1

See more examples

index.js

GitHub: caosbad/api

11
12
13
14
15
16
17
18
19
20
const rxjs = require('rxjs');

exports.Observable = rxjs.Observable;
exports.ConnectableObservable = rxjs.ConnectableObservable;
exports.GroupedObservable = rxjs.GroupedObservable;
exports.observable = rxjs.observable;
exports.Subject = rxjs.Subject;
exports.BehaviorSubject = rxjs.BehaviorSubject;
exports.ReplaySubject = rxjs.ReplaySubject;
exports.AsyncSubject = rxjs.AsyncSubject;

299

0

1

See more examples