幽灵资源网 Design By www.bzswh.com
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<string>(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") } }
幽灵资源网 Design By www.bzswh.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件! 如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
幽灵资源网 Design By www.bzswh.com
暂无评论...
《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。