Usando uma matriz de Observable Object com ngFor e Async Pipe Angular 2

91

Estou tentando entender como usar Observáveis ​​no Angular 2. Tenho este serviço:

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));
    }
}

Este BehaviorSubject recebe novos valores de outro serviço:

that._appointmentChoiceStore._appointmentChoices.next(parseObject)

Eu me inscrevo na forma de um observável no componente que desejo exibi-lo em:

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
        })
    }
}

E a tentativa de exibir na visualização como:

  <li *ngFor="#appointment of _nextFourAppointments.availabilities | async">
         <div class="text-left appointment-flex">{{appointment | date: 'EEE' | uppercase}}

No entanto, as disponibilidades ainda não são uma propriedade do objeto observável, portanto, ocorre um erro, mesmo que eu tenha definido isso na interface de disponibilidades como:

export interface Availabilities {
  "availabilities": string[],
  "length": number
}

Como posso exibir uma matriz de forma assíncrona de um objeto observável com o pipe assíncrono e * ngFor? A mensagem de erro que recebo é:

browser_adapter.js:77 ORIGINAL EXCEPTION: TypeError: Cannot read property 'availabilties' of undefined
C. Kearns
fonte
Qual é a mensagem de erro real?
Günter Zöchbauer
editado para adicionar erro
C. Kearns
com o angular-rc1 mais recente, a sintaxe é*ngFor="let appointment of _nextFourAppointments.availabilities | async">
Jagannath
isso é verdade, mas não está causando o erro. simplesmente lança um aviso.
C. Kearns
3
Acredito que haja um erro de digitação em algum lugar. O erro diz availabiltiesenquanto deveria haveravailabilities
Ivan Sivak

Respostas:

152

Aqui está um exemplo

// 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>
Relu Mesaros
fonte
minha função get está retornando um assunto: public _appointmentChoices: Subject<any> = new Subject() getAppointments() { return this._appointmentChoices.map(object=>object.availabilities).subscribe() } no controlador quando eu configuro igual, recebo o erro:, browser_adapter.js:77Error: Invalid argument '[object Object]' for pipe 'AsyncPipe'como faço para transformar o assunto em um observável?
C. Kearns
public _appointmentChoices: Subject<any> = new Subject() getAppointments() { return (this._appointmentChoices.map(object=>object.availabilities).asObservable()) } } isso me dá o erro property asObservable does not exist on type observable:, mas _appointmentChoices é um Subject?
C. Kearns
Já era um observável! Eu só precisava assinar!
C. Kearns
Tive um problema adicional com a integração de assuntos. Aqui está um StackBlitz usando observáveis ​​e assuntos: stackblitz.com/edit/subject-as-observable-list-example
IceWarrior353
12

Quem nunca também tropeça neste post.

Eu acredito que é a maneira correta:

  <div *ngFor="let appointment of (_nextFourAppointments | async).availabilities;"> 
    <div>{{ appointment }}</div>
  </div>
Martin Søberg
fonte
1

Acho que o que você está procurando é isso

<article *ngFor="let news of (news$ | async)?.articles">
<h4 class="head">{{news.title}}</h4>
<div class="desc"> {{news.description}}</div>
<footer>
    {{news.author}}
</footer>

Nixon Mathew
fonte
1

Se você não tem um array, mas está tentando usar seu observável como um array, embora seja um stream de objetos, isso não funcionará nativamente. Mostro como consertar isso a seguir, supondo que você só se preocupe em adicionar objetos ao observável, não em excluí-los.

Se você estiver tentando usar um observável cuja fonte seja do tipo BehaviorSubject, altere-o para ReplaySubject e em seu componente assine-o assim:

Componente

this.messages$ = this.chatService.messages$.pipe(scan((acc, val) => [...acc, val], []));

Html

<div class="message-list" *ngFor="let item of messages$ | async">
Post Impatica
fonte
Em vez da scanoperadora, você pode usar.pipe(toArray())
MotKohn
Outra armadilha ao criar o seu próprio Subjecté não ligar complete(). O acumulador nunca será executado.
MotKohn