溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要講解了在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<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")
}
}看完上述內容，是不是對在TypeScript中如何使用RxJS有進一步的了解，如果還想學習更多內容，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
