RxJS Angular 2 Syntax

Question

В настоящее время я читаю библиотеки RxJS и занимаю некоторое время, чтобы пройти через некоторые из классов, предлагаемых некоторыми из его архитекторов и разработчиков, с целью включения этих знаний в приложение с угловым2. Мне сложно, хотя я не могу понять, как изменить синтаксис, поэтому я могу использовать RxJS, как я вижу в любом из примеров, которые не являются угловыми2. Например, если я пытаюсь создать наблюдателя в конструкторе:

this.$mouseObserver = Rx.Observer.create(
     function (x) { 
    console.log('Next: %s', x); 
    }, 
    function (err) { 
    console.log('Error: %s', err); 
    }, 
    function() { 
    console.log('Completed'); 
    }); 

Rx всегда приходит неопределенными, даже после его импорта. Наблюдатель и Наблюдаемый импорт штрафа, а также методы для них. Я что-то пропустил? Каждая часть документации для RxJS начинается почти с Rx., но я не видел ни одного учебника Angular 2, в котором используется этот синтаксис.

Answer 1

Если вы:

import { Observer } from 'rxjs/Observer'; 

или:

import { Observer } from 'rxjs/Rx'; 

вы будете использовать Observer.create (без Rx.). Чтобы использовать Rx.Observer, вам необходимо import * as Rx from 'rxjs/Rx';

Обычно предпочтительнее импортировать отдельные классы/объекты, поэтому вы видите больше импорта этой формы. Rx. форма обычно наблюдается, когда библиотека Rx не импортируется (например, проект не построен в node среде), но ссылки из <script src="..."> тега

EDIT: В ответ на комментарий С. Кернс в:

наблюдателей , в определении типа RxJS 5, является интерфейсом. Он не имеет реализации, и он не компилируется в javascript. Таким образом, вы не можете назвать какую-либо функцию. Интерфейс объявлен как:

export interface Observer<T> { 
    isUnsubscribed?: boolean; 
    next: (value: T) => void; 
    error: (err: any) => void; 
    complete:() => void; 
} 

В вашем случае, объявить $mouseObserver как Observer<any> и это должно работать:

this.$mouseObserver = { 
    next: function (x) { 
    console.log('Next: %s', x); 
    }, 
    error: function (err) { 
    console.log('Error: %s', err); 
    }, 
    complete: function() { 
    console.log('Completed'); 
    } 
};