Как правильно объявить или потребовать в ссылке библиотеку rxjs? - PullRequest
Новая
       5

Как правильно объявить или потребовать в ссылке библиотеку rxjs?

0 голосов
/ 13 ноября 2018

Используя nodejs и машинопись для просмотра другого ответа на другой вопрос , я получаю это исключение:

TypeError: интервал $ .zip не является функцией

Мой код (rxjs2.ts): 

{
    var Rx = require('rxjs');

    const interval$ = Rx.interval(1000);
    const items$ = Rx.from([1,2,3]);

    const itemsOverTime$ = interval$.zip(items$).repeat();

    itemsOverTime$.subscribe(([time, val]) => {
    console.log(val);
    // 1
    // 2
    // 3
    // 1
    // 2
    // 3
    });
}

Запуск этого из консоли VSCode, например: node rxjs2.ts

Мой пакет-lock.json 

{
  "requires": true,
  "lockfileVersion": 1,
  "dependencies": {
    "@types/node": {
      "version": "10.12.2",
      "resolved": "https://registry.npmjs.org/@types/node/-/node-10.12.2.tgz",
      "integrity": "sha512-53ElVDSnZeFUUFIYzI8WLQ25IhWzb6vbddNp8UHlXQyU0ET2RhV5zg0NfubzU7iNMh5bBXb0htCzfvrSVNgzaQ=="
    },
    "rxjs": {
      "version": "6.3.3",
      "resolved": "https://registry.npmjs.org/rxjs/-/rxjs-6.3.3.tgz",
      "integrity": "sha512-JTWmoY9tWCs7zvIk/CvRjhjGaOd+OVBM987mxFo+OW66cGpdKjZcpmc74ES1sB//7Kl/PAe8+wEakuhG4pcgOw==",
      "requires": {
        "tslib": "1.9.3"
      }
    },
    "tslib": {
      "version": "1.9.3",
      "resolved": "https://registry.npmjs.org/tslib/-/tslib-1.9.3.tgz",
      "integrity": "sha512-4krF8scpejhaOgqzBEcGM7yDIEfi0/8+8zDRZhNZZ2kjmHJ4hv3zCbQWxoJGz1iw5U0Jl0nma13xzHXcncMavQ=="
    }
  }
}

1 Ответ

0 голосов
/ 13 ноября 2018

Ваш импорт неправильный, а также способ доступа к ним.

Это должно работать:

StackBlitz 

import { interval, from, zip } from 'rxjs';
import { repeat } from 'rxjs/operators';

const interval$ = interval(1000);
const items$ = from([1, 2, 3]);

const itemsOverTime$ = zip(interval$, items$).pipe(repeat());

itemsOverTime$.subscribe(([time, val]) => {
  console.log(val);
  // 1
  // 2
  // 3
  // 1
  // 2
  // 3
});

ОБНОВЛЕНИЕ: Вот решение для импорта CommonJS.Вам необходимо установить rxjs-compat с npm, если вы предпочитаете использовать старый синтаксис и импорт.Посмотрите на эту документацию Rxjs Doc .

Stackblitz 

const Rx = require('rxjs/Rx');
const repeat = require('rxjs/operator/repeat');


const interval$ = Rx.Observable.interval(1000);
const items$ = Rx.Observable.from([1, 2, 3]);

const itemsOverTime$ = Rx.Observable.zip(interval$, items$).repeat();

itemsOverTime$.subscribe(([time, val]) => {
   console.log(val);
   // 1
   // 2
   // 3
   // 1
   // 2
   // 3
});

ОБНОВЛЕНИЕ 2:

Для CommonJS и новой версии RxJ вам нужно сделать это так:

StackBlitz 

const Rx = require('rxjs');
const RxOp = require('rxjs/operators');

const interval$ = Rx.interval(1000);
const items$ = Rx.from([1, 2, 3]);

const itemsOverTime$ = Rx.zip(interval$, items$).pipe(RxOp.repeat());

itemsOverTime$.subscribe(([time, val]) => {
  console.log(val);
  // 1
  // 2
  // 3
  // 1
  // 2
  // 3
});
...