How to use the fromEvent function from rxjs

connection.js

GitHub: steveholgado/rxjs-chat-app

7
8
9
10
11
12
13
14
15
16

// Stream of connections
const connection$ = io$
  .pipe(
    switchMap(io =>
      fromEvent(io, 'connection')
        .pipe(
          map(client => ({ io, client }))
        )
    )

6

26

4

+ 7 other calls in file

extract_grenades.js

GitHub: shoffing/csgo-demo-scripts

25
26
27
28
29
30
31
32
33

const gameStarts$ = fromEvent(demo.gameEvents, 'round_start').pipe(
    tap(() => console.log('GAME STARTED')),
    first(),
);
const gameEnds$ = fromEvent(demo, 'end').pipe(
    tap(() => console.log('GAME ENDED')),
    first(),
);

0

10

2

+ 13 other calls in file

extract_1vn.js

GitHub: shoffing/csgo-demo-scripts

44
45
46
47
48
49
50
51
52
53
);

// Some demos have round_end not round_officially_ended. Some are the other way around.
// So we'll use both and do the best we can with that.
let lastRoundScore = {};
const roundEndsWinner$ = fromEvent(demo.gameEvents, 'round_end').pipe(
    rxop.filter(e => (e.winner === demofile.TEAM_TERRORISTS || e.winner === demofile.TEAM_CTS) && e.reason < 11),
    rxop.map(e => {
        if (e.winner === demofile.TEAM_TERRORISTS) return {winner: 'T'};
        else if (e.winner === demofile.TEAM_CTS) return {winner: 'CT'};

0

10

2

+ 9 other calls in file

index.ts

GitHub: visualkhh/pro-game

28
29
30
31
32
33
34
35
36
37
input.min = '0';
input.max = '100';
it.value = (Math.random() * (100 - 0 + 1) + 0);
input.value = it.value.toString();
input.className = 'slider';
fromEvent(input, 'mousemove').subscribe((event: Event) => {
    let target: any = event.target!;
    let newVar = target['value'];
    // console.log(newVar);
    it.value = Number(newVar);

0

3

3

+ 11 other calls in file

communicationFunctions.js

GitHub: embarklabs/embark

75
76
77
78
79
80
81
82
83
84
  subOptions.symKeyID = symKeyID;
}

const emitter = subscribe('messages', subOptions);

const obsData = fromEvent(emitter, 'data').pipe(map(result => ({
  data: JSON.parse(toAscii(result.payload)),
  payload: result.payload,
  recipientPublicKey: result.recipientPublicKey,
  result,

533

0

132

+ 7 other calls in file

buttonPressesEpic.js

GitHub: Sawtaytoes/Smart-Home-Services

16
17
18
19
20
21
22
23
24
25
ofType(ADDED_FLIC_CLIENT),
mergeMap(({
        flicClient,
        hostname,
}) => (
        fromEvent(
                flicClient,
                'ready',
        )
        .pipe(

2

6

2

+ 11 other calls in file

index.js

GitHub: insightfuls/inquirer-tree-prompt

95
96
97
98
99
100
101
102
103
104
        .forEach(this.onSpaceKey.bind(this));

        function normalizeKeypressEvents(value, key) {
                return { value: value, key: key || {} };
        }
        fromEvent(this.rl.input, 'keypress', normalizeKeypressEvents)
        .pipe(filter(({ key }) => key && key.name === 'tab'), share())
        .pipe(takeUntil(validation.success))
        .forEach(this.onTabKey.bind(this));
}

3

3

3

actions.js

GitHub: rhygg/askio.js

10
11
12
13
14
15
16
17
18
19
  .pipe(takeUntil(fromEvent(rl, 'close')))
  // Ignore `enter` key. On the readline, we only care about the `line` event.
  .pipe(filter(({ key }) => key.name !== 'enter' && key.name !== 'return'));

return {
  line: fromEvent(rl, 'line'),
  keypress: keypress,

  normalizedUpKey: keypress.pipe(
    filter(

0

2

1

+ 3 other calls in file

index.ts

GitHub: bkoplin/inquirer-file-tree-selection

152
153
154
155
156
157
158
159
160
  .forEach(this.onSpaceKey.bind(this, false));

function normalizeKeypressEvents(value, key) {
  return { value: value, key: key || {} };
}
fromEvent((this.rl as any).input, 'keypress', normalizeKeypressEvents)
  .pipe(filter(({ key }) => key && key.name === 'tab'), share())
  .pipe(takeUntil(validation.success))
  .forEach(this.onSpaceKey.bind(this, true));

25

0

0

+ 11 other calls in file

index.js

GitHub: hatchapp/game-server

50
51
52
53
54
55
56
57
58
 * Given a ring, creates a stream out of its move actions
 * @param ring
 * @returns {Observable<*>}
 */
function createRingMoveStream(ring){
        const move$ = fromEvent(ring, 'move');
        const err$ = fromEvent(ring, 'error').pipe(
                mergeMap((err) => throwError(err))
        );

0

1

5

+ 7 other calls in file

index.js

GitHub: caosbad/api

48
49
50
51
52
53
54
55
56
57
exports.concat = rxjs.concat;
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;

299

0

1

cluster.js

GitHub: fadi12321/test-for-deep-8

472
473
474
475
476
477
478
479
480
481

// close the stdio target if we have one defined
if (stdioTarget) {
  Rx.combineLatest([
    Rx.fromEvent(this._process.stderr, 'end'),
    Rx.fromEvent(this._process.stdout, 'end'),
  ])
    .pipe(Rx.first())
    .subscribe(() => {
      stdioTarget.end();

0

0

1

+ 203 other calls in file

command.js

GitHub: haley10309/graduation_project_frontend

61
62
63
64
65
66
67
68
69
70
    this.process = undefined;
    const endDate = new Date(Date.now());
    this.timer.next({ startDate, endDate });
    this.error.next(event);
});
Rx.fromEvent(child, 'close').subscribe(([exitCode, signal]) => {
    this.process = undefined;
    this.exited = true;
    const endDate = new Date(Date.now());
    this.timer.next({ startDate, endDate });

0

0

1

+ 21 other calls in file

input-handler.js

GitHub: haley10309/graduation_project_frontend

45
46
47
48
49
50
51
52
53
54
handle(commands) {
    const { inputStream } = this;
    if (!inputStream) {
        return { commands };
    }
    Rx.fromEvent(inputStream, 'data')
        .pipe((0, operators_1.map)((data) => String(data)))
        .subscribe((data) => {
        const dataParts = data.split(/:(.+)/);
        const targetId = dataParts.length > 1 ? dataParts[0] : this.defaultInputTarget;

0

0

1

+ 9 other calls in file

App.js

GitHub: twlevelup/syd-2019-s1-green

59
60
61
62
63
64
65
66
67
68
}

setupRxjsListeners() {
  this.watchMouseDown$ = fromEvent(this.watchContainer, 'mousedown').pipe(getRxjsTarget())
  this.watchMouseUp$ = fromEvent(this.watchContainer, 'mouseup').pipe(getRxjsTarget())
  this.watchKeyDown$ = fromEvent(this.wholePage, 'keydown').pipe(getRxjsTargetFromKey())
  this.watchKeyUp$ = fromEvent(this.wholePage, 'keyup').pipe(getRxjsTargetFromKey())

  this.mergeEvents();
  this.subscribeToEvents();

0

0

34

+ 15 other calls in file

046-skip.js

GitHub: szy0syz/hi-RxJS

14
15
16
17
18
19
20
21
22
);
// .subscribe(console.log);

// 网页载入完毕后就开始计时，等啊等，等到 button 点击后开始连续打印
const button = document.getElementById('submit');
const buttonEvents = fromEvent(button, 'click');

interval(1000).pipe(take(10), skipUntil(buttonEvents));
// .subscribe(console.log);

0

0

2

+ 3 other calls in file

fileselect.component.js

GitHub: cuongnqph06515/node_modules

292
293
294
295
296
297
298
299
300
301
var _this = this;
if (!kendo_angular_common_1.isDocumentAvailable()) {
    return;
}
this.ngZone.runOutsideAngular(function () {
    _this.documentClick = rxjs_1.fromEvent(document, 'click').pipe(operators_1.filter(function (event) {
        return !(_this.wrapper !== event.target && _this.wrapper.contains(event.target));
    }));
    _this.blurSubscription = rxjs_1.merge(_this.documentClick, _this.navigation.onTab).subscribe(function () {
        if (_this.navigation.focused) {

0

0

0

virtualization.component.js

GitHub: cuongnqph06515/node_modules

224
225
226
227
228
229
230
231
232
233
};
VirtualizationComponent.prototype.scrollStep = function (start, end) {
    return Math.abs(end - start) / (this.scrollDuration / FRAME_DURATION);
};
VirtualizationComponent.prototype.scroll$ = function () {
    return kendo_angular_common_1.isDocumentAvailable() ? rxjs_1.fromEvent(this.container.nativeElement, 'scroll') : rxjs_1.EMPTY;
};
VirtualizationComponent.prototype.initServices = function () {
    var _this = this;
    this.rowHeightService = this.createRowHeightService();

0

0

0

tooltip.directive.js

GitHub: cuongnqph06515/node_modules

81
82
83
84
85
86
87
88
89
90
    var filterElement = utils_1.closest(e.target, _this.filter);
    if (filterElement) {
        _this.hideElementTitle({ nativeElement: filterElement });
    }
});
_this.mouseOverSubscription = rxjs_1.fromEvent(wrapper, 'mouseover')
    .pipe(operators_1.debounceTime(100), operators_1.filter(function () { return _this.filter !== ''; }))
    .subscribe(function (e) { return _this.onMouseOver(e); });
_this.mouseOutSubscription = rxjs_1.fromEvent(wrapper, 'mouseout')
    .pipe(operators_1.debounceTime(100))

0

0

0

+ 4 other calls in file

toolbar.component.js

GitHub: cuongnqph06515/node_modules

203
204
205
206
207
208
209
210
211
212
    var rtl = _a.rtl;
    return (_this.direction = rtl ? 'rtl' : 'ltr');
});
if (kendo_angular_common_3.isDocumentAvailable()) {
    this.zone.runOutsideAngular(function () {
        return (_this.closeOverflowSubscription = rxjs_1.fromEvent(document, 'click')
            .pipe(operators_1.filter(function () { return !!_this.popupRef; }), operators_1.filter(function (ev) { return !_this.popupRef.popup.instance.container.nativeElement.contains(ev.target); }), operators_1.filter(function (ev) { return !_this.overflowButton.nativeElement.contains(ev.target); }))
            .subscribe(function () {
            _this.zone.run(function () {
                _this.popupOpen = false;

0

0

0