Skip to content

delay

延迟操作符,将输入流的数据延迟指定时间后推送给订阅节点。

image

类型

typescript
type delay = <T>(delayTime: number) => (observable$: Observable<T>) => Observable<T>

详情

  • 接收一个延迟时间参数(毫秒),将数据延迟指定时间后推送给订阅节点

示例

typescript
import { $, delay } from 'fluth'

const stream$ = $(1)

// 使用 delay 操作符,延迟 1000ms
const delayed$ = stream$.pipe(delay(1000))

delayed$.then((value) => {
  console.log('延迟后的值:', value)
})

stream$.next(2)
stream$.next(3)

// 输出:
// 延迟 1000ms 后输出: 延迟后的值: 2
// 延迟 1000ms 后输出: 延迟后的值: 3