Я пытаюсь понять, как использовать Observables в Angular 2. У меня есть такая услуга:
import {Injectable, EventEmitter, ViewChild} from '@angular/core';
import {Observable} from "rxjs/Observable";
import {Subject} from "rxjs/Subject";
import {BehaviorSubject} from "rxjs/Rx";
import {Availabilities} from './availabilities-interface'
@Injectable()
export class AppointmentChoiceStore {
public _appointmentChoices: BehaviorSubject<Availabilities> = new BehaviorSubject<Availabilities>({"availabilities": [''], "length": 0})
constructor() {}
getAppointments() {
return this.asObservable(this._appointmentChoices)
}
asObservable(subject: Subject<any>) {
return new Observable(fn => subject.subscribe(fn));
}
}
Этот объект BehaviorSubject получает новые значения из другой службы:
that._appointmentChoiceStore._appointmentChoices.next(parseObject)
Я подписываюсь на него в виде наблюдаемого в компоненте, в котором я хочу его отображать:
import {Component, OnInit, AfterViewInit} from '@angular/core'
import {AppointmentChoiceStore} from '../shared/appointment-choice-service'
import {Observable} from 'rxjs/Observable'
import {Subject} from 'rxjs/Subject'
import {BehaviorSubject} from "rxjs/Rx";
import {Availabilities} from '../shared/availabilities-interface'
declare const moment: any
@Component({
selector: 'my-appointment-choice',
template: require('./appointmentchoice-template.html'),
styles: [require('./appointmentchoice-style.css')],
pipes: [CustomPipe]
})
export class AppointmentChoiceComponent implements OnInit, AfterViewInit {
private _nextFourAppointments: Observable<string[]>
constructor(private _appointmentChoiceStore: AppointmentChoiceStore) {
this._appointmentChoiceStore.getAppointments().subscribe(function(value) {
this._nextFourAppointments = value
})
}
}
И попытка отобразить в представлении так:
<li *ngFor="#appointment of _nextFourAppointments.availabilities | async">
<div class="text-left appointment-flex">{{appointment | date: 'EEE' | uppercase}}
Однако доступность еще не является свойством наблюдаемого объекта, поэтому она выдает ошибку, даже если подумал, что я определяю ее в интерфейсе доступности так:
export interface Availabilities {
"availabilities": string[],
"length": number
}
Как я могу асинхронно отображать массив из наблюдаемого объекта с помощью async pipe и * ngFor? Я получаю следующее сообщение об ошибке:
browser_adapter.js:77 ORIGINAL EXCEPTION: TypeError: Cannot read property 'availabilties' of undefined
typescript
angular
rxjs
observable
К. Кирнс
источник
источник
*ngFor="let appointment of _nextFourAppointments.availabilities | async">
availabilties
а должна бытьavailabilities
Ответы:
Вот пример
// in the service getVehicles(){ return Observable.interval(2200).map(i=> [{name: 'car 1'},{name: 'car 2'}]) } // in the controller vehicles: Observable<Array<any>> ngOnInit() { this.vehicles = this._vehicleService.getVehicles(); } // in template <div *ngFor='let vehicle of vehicles | async'> {{vehicle.name}} </div>
источник
public _appointmentChoices: Subject<any> = new Subject() getAppointments() { return this._appointmentChoices.map(object=>object.availabilities).subscribe() }
в контроллере, когда я устанавливаю его равным, я получаю сообщение об ошибке:,browser_adapter.js:77Error: Invalid argument '[object Object]' for pipe 'AsyncPipe'
как мне превратить объект в наблюдаемое?public _appointmentChoices: Subject<any> = new Subject() getAppointments() { return (this._appointmentChoices.map(object=>object.availabilities).asObservable()) } }
это дает мне ошибку:,property asObservable does not exist on type observable
но _appointmentChoices - этоSubject
?Кто нибудь тоже наткнется на этот пост.
Я верю, что это правильный путь:
<div *ngFor="let appointment of (_nextFourAppointments | async).availabilities;"> <div>{{ appointment }}</div> </div>
источник
Я думаю, что ты ищешь это
<article *ngFor="let news of (news$ | async)?.articles"> <h4 class="head">{{news.title}}</h4> <div class="desc"> {{news.description}}</div> <footer> {{news.author}} </footer>
источник
Если у вас нет массива, но вы пытаетесь использовать наблюдаемый объект как массив, даже если это поток объектов, это не будет работать изначально. Ниже я покажу, как исправить это, предполагая, что вы заботитесь только о добавлении объектов к наблюдаемому, а не об их удалении.
Если вы пытаетесь использовать наблюдаемый объект, источник которого имеет тип BehaviorSubject, измените его на ReplaySubject, а затем в своем компоненте подпишитесь на него следующим образом:
Составная часть
this.messages$ = this.chatService.messages$.pipe(scan((acc, val) => [...acc, val], []));
HTML
<div class="message-list" *ngFor="let item of messages$ | async">
источник
scan
оператора можно использовать.pipe(toArray())
Subject
не звонкаcomplete()
. Аккумулятор никогда не запустится.