在上面的例子中,我们从头开始创建Observable,这在理解Observable的解剖结构时特别有用。
但是,我们将经常从回调,promise,事件,集合或使用API上可用的许多运算符创建Observable。
Observable HTTP Events
任何Web应用程序中的常见操作是向服务器获取或发布数据。 Angular应用程序使用Http库来实现这一点,它以前使用Promises以异步方式操作。 更新的Http库现在合并了Observable,用于触发事件和获取新数据。 让我们快速浏览一下:
import {Component} from '@angular/core';
import {Http} from '@angular/http';
import 'rxjs/Rx';
@Component({
selector: 'app',
template: `
<b>Angular 2 HTTP requests using RxJs Observables!</b>
<ul>
<li *ngFor="let doctor of doctors">{{doctor.name}}</li>
</ul>
`
})
export class MyApp {
private doctors = [];
constructor(http: Http) {
http.get('http://jsonplaceholder.typicode.com/users/')
.flatMap((data) => data.json())
.subscribe((data) => {
this.doctors.push(data);
});
}
}
这个基本示例概述了Http库常见例程如get,post,put和delete所有返回Observables,允许我们异步处理任何结果数据。
Observable Form Events
让我们来看看Observables如何在Angular 2形式中使用。 表单中的每个字段都被视为一个Observable,我们可以订阅和监听对输入字段的值所做的任何更改。
import {Component} from '@angular/core';
import {FormControl, FormGroup, FormBuilder} from '@angular/forms';
import 'rxjs/add/operator/filter';
import 'rxjs/add/operator/map';
@Component({
selector: 'app',
template: `
<form [formGroup]="coolForm">
<input formControlName="email">
</form>
<div>
<b>You Typed Reversed:</b> {{data}}
</div>
`
})
export class MyApp {
email: FormControl;
coolForm: FormGroup;
data: string;
constructor(private fb: FormBuilder) {
this.email = new FormControl();
this.coolForm = fb.group({
email: this.email
});
this.email.valueChanges
.filter(n=>n)
.map(n=>n.split('').reverse().join(''))
.subscribe(value => this.data = value);
}
}
这里我们通过初始化一个新的FormControl字段并将其分组到一个绑定到coolForm HTML表单的FormGroup中来创建一个新的表单。 控件字段有一个属性.valueChanges,它返回一个我们可以订阅的Observable。 现在每当用户在字段中输入内容时,我们会立即得到它。