Observable 包装
在 Observable 剖析章节中我们只学到了关键操作符 next()
、error()
和 complete()
,如果是我们自己定义的 Observable 的话,可以使用这些方法来驱动 Observable 。我们还学到了,这些方法会触发相应的回调函数。
用 Observable 包装意味着接收一些非 Observable 的东西并将其转换为 Observable,这样就可以很好的与其它 Observable 配合使用。同样还意味着现在我们可以使用操作符了。
包装 ajax 调用
let stream = Rx.Observable.create((observer) => {
let request = new XMLHttpRequest();
request.open( ‘GET’, ‘url’ );
request.onload =() =>{
if(request.status === 200) {
observer.next( request.response );
observer.complete();
} else {
observer.error('error happened');
}
}
request.onerror = () => {
observer.error('error happened')
}
request.send();
})
stream.subscribe(
(data) => console.log( data )
)
这里我们需要做的三件事:发出数据
、错误处理
和关闭流
发出数据
if(request.status === 200) {
observer.next( request.response ) // 发出数据
}
处理潜在的错误
else {
observer.error('error happened');
}
关闭流
if(request.status === 200) {
observer.next( request.response )
observer.complete() // 关闭流,因为我们不想要更多的数据了
}
包装语音音频 API
console.clear();
const { Observable } = Rx;
const speechRecognition$ = new Observable(observer => {
const speech = new webkitSpeechRecognition();
speech.onresult = (event) => {
observer.next(event);
observer.complete();
};
speech.start();
return () => {
speech.stop();
}
});
const say = (text) => new Observable(observer => {
const utterance = new SpeechSynthesisUtterance(text);
utterance.onend = (e) => {
observer.next(e);
observer.complete();
};
speechSynthesis.speak(utterance);
});
const button = document.querySelector("button");
const heyClick$ = Observable.fromEvent(button, 'click');
heyClick$
.switchMap(e => speechRecognition$)
.map(e => e.results[0][0].transcript)
.map(text => {
switch (text) {
case 'I want':
return 'candy';
case 'hi':
case 'ice ice':
return 'baby';
case 'hello':
return 'Is it me you are looking for';
case 'make me a sandwich':
case 'get me a sandwich':
return 'do it yo damn self';
case 'why are you being so sexist':
return 'you made me that way';
default:
return `I don't understand: "${text}"`;
}
})
.concatMap(say)
.subscribe(e => console.log(e));
语音识别流
这将激活浏览器的麦克风并记录我们的语音
const speechRecognition$ = new Observable(observer => {
const speech = new webkitSpeechRecognition();
speech.onresult = (event) => {
observer.next(event);
observer.complete();
};
speech.start();
return () => {
speech.stop();
}
});
这段代码建立了语音识别 API,然后等待响应,并在响应一次后完成流,很像第一个使用 AJAX 的示例。
注意还定义一个函数用来清理
return () => {
speech.stop();
}
所以我们可以通过调用 speechRecognition.unsubscribe()
来清理系统资源
语音合成, say
函数 say
负责发出你想要表达的语音。
const say = (text) => new Observable(observer => {
const utterance = new SpeechSynthesisUtterance(text);
utterance.onend = (e) => {
observer.next(e);
observer.complete();
};
speechSynthesis.speak(utterance);
});
主体流 hey$
heyClick$
.switchMap(e => speechRecognition$)
.map(e => e.results[0][0].transcript)
.map(text => {
switch (text) {
case 'I want':
return 'candy';
case 'hi':
case 'ice ice':
return 'baby';
case 'hello':
return 'Is it me you are looking for';
case 'make me a sandwich':
case 'get me a sandwich':
return 'do it yo damn self';
case 'why are you being so sexist':
return 'you made me that way';
default:
return `I don't understand: "${text}"`;
}
})
.concatMap(say)
.subscribe(e => console.log(e));
整体逻辑应该是这样的:点击按钮激活 heyClick$
。speechRecognition$
监听我们说了什么并把结果发送给 heyClick$
的转换逻辑,转换逻辑的结果将由 say
Observable 发出声音。
总结
这两个 Observable 包装示例其中一个是简单些的 Ajax,而另一个是有一点点高级的语音 API 。但原理都是相同的: 1)数据是通过调用 next()
来发送的 2)如果没有更多的数据要发送则调用 complete()
3)如果有需要的话,定义一个清理函数可以通过 unsubscribe()
来调用 4)在合适的地方通过调用 error()
来进行错误处理。(只在第一个示例中这样做了)