重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章主要讲解了在TypeScript中如何使用RxJS,内容清晰明了,对此有兴趣的小伙伴可以学习一下,相信大家阅读完之后会有帮助。
建网站原本是网站策划师、网络程序员、网页设计师等,应用各种网络程序开发技术和网页设计技术配合操作的协同工作。成都创新互联专业提供网站设计制作、做网站,网页设计,网站制作(企业站、成都响应式网站建设公司、电商门户网站)等服务,从网站深度策划、搜索引擎友好度优化到用户体验的提升,我们力求做到极致!
1. 安装
# 安装 typescript, rxjs 包 npm install -D typescript @types/node npm install rxjs
2. 使用
2.1 使用 from 来从数组生成源
RxJS 有许多创建源的方法,如 from, fromEvent..., 这里使用 from做个例子
import {from} from 'rxjs' // 从数组生成可订阅对象 // obser 的对象类型为 Observable let obser = from([1,2,3,4,5]) // 消费对象 // next 当管道中有值流动,就会出发next // 当发生错误是会触发 error // 当循环完数组时,会调用complete obse.subscribe({ next(item) { console.log(item) }, error(err) { console.log(err) }, complete() { console.log("Done") } }
2.2 自定义生成源
import {Observable, from} from 'rxjs' // 新建一个可订阅对象 let obser = new Observable(productor => { // 自定义数据流 productor.next("hello") productor.next("world") setTimeout(()=>{ productor.next("After 1 Sec") productor.complete() }, 1000) }) // 消费 obse.subscribe({ next(item) { console.log(item) }, error(err) { console.log(err) }, complete() { console.log("Done") } }
3. 实际例子,使用 redis
3.1 安装 Redis
npm install redis @types/redis
3.2 使用
import {RedisClient} from "redis" import {Observable} from "rxjs" // 连接redis, redisclient 的构造类型是”ClientOpt接口“,只要是符合其字段定义的对象就可以 let reids = new RedisClient({ host:"localhost", port:6379 }) // redis的操作都是异步操作,通过回调使用,很容易陷入毁掉地狱 redis.set("name", "tom", (err, res)=>{ // 需要在set成功后同步的操作 if(!err) { redis.get("name", (err,res)=> { console.log(res) }) } }) // 可以使用 Promise 封装上面的方法,但我们这里使用 rxjs的事件流 let redisObser = new Observable(productor => { // 这个列子没啥实际用途,只做演示 redis.set("name", "jack", (err, res) => { productor.next(res) productor.complete() }) }) // 消费代码 obse.subscribe({ next(key) { // 读取或其他需保证在 set 后的操作 redis.get(key, (err, res) => { console.log(res) }) }, error(err) { console.log(err) }, complete() { console.log("Query Finish") } }
看完上述内容,是不是对在TypeScript中如何使用RxJS有进一步的了解,如果还想学习更多内容,欢迎关注创新互联行业资讯频道。