Должен ли я «думать» обо всех моих данных как потоках при работе с Observables?

Question

Say мы получаем массив категории как JSON:

[ {id: "111", name: "cat1"}, {id: "222", name: "cat2"}, {id: "333", name: "cat3"} ] 

метод получает его:

getCategories(): Observable<Array<Category>> { 
    return this.http.get('/categories').map(data => data.json()); 
} 

Мы также имеем:

getCategoryById(id): Observable<Category> { 
    return this.getCategories() 
     .map(categories => categories.find(c => c.id === id)); 
} 

Это работает, но мне интересно, если Я использую наблюдаемые правильно.
Должен ли я считать свои категории потоком вместо атомной группы данных?

Код будет:

getCategoriesAsStream(): Observable<Category> { 
    return this.http.get('/categories') 
     .map(data => data.json()) 
     .flatMap(categories => Observable.from(categories)); 
} 

getCategoryById(id): Observable<Category> { 
    return this.getCategoriesAsStream() 
     .find(category => category.id === id); 
} 

Поскольку наблюдаемые/RxProgramming, кажется, новый способ мышления асинхронных операций, я чувствую, что я должен думать, как все потоки. Но я также опасаюсь некоторых подводных камней, которых я не видел сейчас.

Вы знаете, что бы это было? Считаете ли вы, что это слишком сложно переосмыслить мои данные таким образом?

Answer 1

Вы совершенно правы. Для меня Observables являются «как потоки», мы можем фильтровать их, сквошать их и т. Д.

Вам нужно помнить одну вещь. При использовании наблюдаемых с angular2, ваш второй пример может принести вам некоторые проблемы:

Представьте себе следующий шаблон:

<ul> 
    <li *ngFor="let category from (getCategoriesAsStream() | async)">{{category}}</li> 
</ul> 
<!--- async pipe is preferable way to bind observables in template, ie they unsubscribe automatically ----> 

данный шаблон будет оказывать только один элемент, вместо трех, которые вы получили в формате JSON.

Заключительный, observables следует рассматривать как потоки пучков.