I'm trying to display a list of rooms using Angular 4 async pipe and an Observable created with new Observable().
I have a RoomService defined like this:
import { Injectable } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { DatabaseService } from '../core/database.service';
import { Room } from './room';
@Injectable()
export class RoomService {
private store: any;
constructor(private db: DatabaseService) {
this.store = this.db.store('rooms');
}
getRooms(query: any = {}): Observable<Room[]> {
return new Observable(observer => {
this.store.find(query, (error, results) => {
if (error) {
observer.error(error);
} else {
const rooms = results.map(room => {
return new Room(room.building, room.number, room._id);
});
observer.next(rooms);
}
observer.complete();
});
});
}
}
and a RoomListComponent defined like this:
import { Component, OnInit } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { Room } from '../room';
import { RoomService } from '../room.service';
@Component({
selector: 'app-room-list',
templateUrl: './room-list.component.html',
styleUrls: ['./room-list.component.scss']
})
export class RoomListComponent implements OnInit {
rooms$: Observable<Room[]>;
constructor(private roomService: RoomService) {}
ngOnInit() {
this.rooms$ = this.roomService.getRooms();
}
}
And I'm trying to display rooms like this:
<h1>Rooms</h1>
<div *ngIf="$rooms | async as rooms; else loading">
<div *ngFor="let room of rooms">
{{ room.number }}
</div>
</div>
<ng-template #loading>Loading...</ng-template>
But it's not working. The view keep showing Loading... Please can anyone tell me what's wrong with my code?
