快捷導(dǎo)航

RxJS在TypeScript中的簡(jiǎn)單使用詳解

更新時(shí)間：2020年04月13日 14:58:40 作者：rainsay

這篇文章主要介紹了RxJS在TypeScript中的簡(jiǎn)單使用詳解，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

1. 安裝

# 安裝 typescript， rxjs 包
npm install -D typescript @types/node
npm install rxjs

2. 使用

2.1 使用 from 來(lái)從數(shù)組生成源

RxJS 有許多創(chuàng)建源的方法，如 from, fromEvent..., 這里使用 from做個(gè)例子

import {from} from 'rxjs'

// 從數(shù)組生成可訂閱對(duì)象
// obser 的對(duì)象類型為 Observable
let obser = from([1,2,3,4,5])
// 消費(fèi)對(duì)象
// next 當(dāng)管道中有值流動(dòng)，就會(huì)出發(fā)next
// 當(dāng)發(fā)生錯(cuò)誤是會(huì)觸發(fā) error
// 當(dāng)循環(huán)完數(shù)組時(shí)，會(huì)調(diào)用complete
obse.subscribe({
  next(item) {
    console.log(item)
  },
  error(err) {
    console.log(err)
  },
  complete() {
    console.log("Done")
  }
}

2.2 自定義生成源

import {Observable, from} from 'rxjs'

// 新建一個(gè)可訂閱對(duì)象
let obser = new Observable<string>(productor => {
  // 自定義數(shù)據(jù)流
  productor.next("hello")
  productor.next("world")
  setTimeout(()=>{
    productor.next("After 1 Sec")
    productor.complete()
  }, 1000)
})

// 消費(fèi)
obse.subscribe({
  next(item) {
    console.log(item)
  },
  error(err) {
    console.log(err)
  },
  complete() {
    console.log("Done")
  }
}

3. 實(shí)際例子，使用 Redis

3.1 安裝 Redis

npm install redis @types/redis

3.2 使用

import {RedisClient} from "redis"
import {Observable} from "rxjs"
// 連接redis, redisclient 的構(gòu)造類型是”ClientOpt接口“，只要是符合其字段定義的對(duì)象就可以
let reids = new RedisClient({
  host:"localhost",
  port:6379
})
// redis的操作都是異步操作，通過(guò)回調(diào)使用，很容易陷入毀掉地獄
redis.set("name", "tom", (err, res)=>{
  // 需要在set成功后同步的操作
  if(!err) {
    redis.get("name", (err,res)=> {
      console.log(res)
    })
  }
})

// 可以使用 Promise 封裝上面的方法，但我們這里使用 rxjs的事件流
let redisObser = new Observable(productor => {
// 這個(gè)列子沒(méi)啥實(shí)際用途，只做演示
  redis.set("name", "jack", (err, res) => {
    productor.next(res)
    productor.complete()
  })
})
// 消費(fèi)代碼
obse.subscribe({
  next(key) {
    // 讀取或其他需保證在 set 后的操作
    redis.get(key, (err, res) => {
      console.log(res)
    })
  },
  error(err) {
    console.log(err)
  },
  complete() {
    console.log("Query Finish")
  }
}

到此這篇關(guān)于RxJS在TypeScript中的簡(jiǎn)單使用詳解的文章就介紹到這了,更多相關(guān)TypeScript使用RxJS內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: