consoleAll

调试插件，在流链的所有节点上输出执行结果，用于调试和监控数据流，只能在 Stream 节点上使用。

类型定义

consoleAll: (resolvePrefix?: string, rejectPrefix?: string, ignoreUndefined?: boolean) => {
  executeAll: ({
    result,
    status,
    onfulfilled,
    onrejected,
    root,
  }: {
    result: Promise<any> | any
    status: PromiseStatus | null
    onfulfilled?: OnFulfilled
    onrejected?: OnRejected
    root: boolean
  }) => any
}

参数说明

• resolvePrefix (可选): 成功时的控制台前缀，默认为 'resolve'
• rejectPrefix (可选): 失败时的控制台前缀，默认为 'reject'
• ignoreUndefined (可选): 是否忽略 undefined 值的输出，默认为 true

详情

• 在流链的所有节点上执行，而不仅仅是单个节点
• 只在以下情况输出：
  • 根节点（root=true）
  • 有成功处理函数（onfulfilled）的节点
  • 有错误处理函数（onrejected）且状态为 REJECTED 的节点
• 对于 Promise 类型的结果，会等待 Promise 解析后再输出
• 默认忽略 undefined 值的输出（ignoreUndefined=true），可通过第三个参数控制
• 返回原始的 result，不会修改数据流

示例

场景 1：基础调试输出

import { $ } from 'fluth'
import { consoleAll } from 'fluth'

const stream$ = $().use(consoleAll())

stream$.next(1)
// 输出: resolve 1

const promise = Promise.resolve(2)
stream$.next(promise)
// 输出: resolve 2

场景 2：流链调试输出

import { $ } from 'fluth'
import { consoleAll } from 'fluth'

const promise$ = $().use(consoleAll())

promise$.then((value) => value + 1).then((value) => value + 1)

promise$.next(1)
// 输出：
// resolve 1
// resolve 2
// resolve 3

场景 3：自定义前缀调试输出

import { $ } from 'fluth'
import { consoleAll } from 'fluth'

// 自定义前缀
const promise$ = $().use(consoleAll('成功', '失败'))

promise$.then((value) => value + 1)

promise$.next(1)
// 输出：
// 成功 1
// 成功 2

const rejectedPromise = Promise.reject(new Error('错误'))
promise$.next(rejectedPromise)
// 输出：失败 Error: 错误

场景 4：与操作符结合调试输出

import { $ } from 'fluth'
import { consoleAll, debounce } from 'fluth'

const promise$ = $()
  .use(consoleAll())
  .pipe(debounce(100))
  .then((value) => value + 1)

promise$.next(1)
promise$.next(2)
promise$.next(3)
promise$.next(4)
promise$.next(5)
// 输出：
// resolve 1
// resolve 2
// resolve 3
// resolve 4
// resolve 5
// 等待 100ms 后输出：resolve 6

场景 5：undefined 值处理

import { $ } from 'fluth'
import { consoleAll } from 'fluth'

// 默认忽略 undefined 值
const stream1$ = $().use(consoleAll())
stream1$.next(undefined) // 不输出
stream1$.next(null) // 输出: resolve null
stream1$.next(0) // 输出: resolve 0
stream1$.next('') // 输出: resolve ""
stream1$.next(false) // 输出: resolve false

// 不忽略 undefined 值
const stream2$ = $().use(consoleAll('resolve', 'reject', false))
stream2$.next(undefined) // 输出: resolve undefined

场景 6：边界情况处理

import { $ } from 'fluth'
import { consoleAll } from 'fluth'

const stream$ = $().use(consoleAll())

// 测试各种边界值
stream$.next(null) // 输出: resolve null
stream$.next(0) // 输出: resolve 0
stream$.next('') // 输出: resolve ""
stream$.next(false) // 输出: resolve false
stream$.next(undefined) // 默认不输出（被忽略）

// Promise 边界情况
const resolveUndefined = Promise.resolve(undefined)
stream$.next(resolveUndefined) // 不输出（undefined 被忽略）

const rejectUndefined = Promise.reject(undefined)
stream$.next(rejectUndefined) // 不输出（undefined 被忽略）

场景 7：移除插件

import { $ } from 'fluth'
import { consoleAll } from 'fluth'

const plugin = consoleAll()
const stream$ = $().use(plugin)

stream$.then((value) => value + 1)
stream$.next(1)
// 输出: resolve 1, resolve 2

stream$.remove(plugin)
stream$.next(2)
// 不再输出