RxJS 在 TypeScript 中的簡單使用

RxJS 在 TypeScript 中的使用

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")
    }
}