TypeError: You provided 'undefined' where a stream was expected. #36
Description
Error log
TypeError: You provided 'undefined' where a stream was expected. You can provide an Observable, Promise, ReadableStream, Array, AsyncIterable, or Iterable.
at Object.createInvalidObservableTypeError (/app/node_modules/rxjs/dist/cjs/internal/util/throwUnobservableError.js:5:12)
at innerFrom (/app/node_modules/rxjs/dist/cjs/internal/observable/from.js:98:36)
at Object.from (/app/node_modules/rxjs/dist/cjs/internal/observable/from.js:71:66)
at reset$ (/app/node_modules/wechaty-redux/dist/src/duck/rx-async.js:50:35)
at doInnerSub (/app/node_modules/rxjs/dist/cjs/internal/operators/mergeInternals.js:21:26)
at outerNext (/app/node_modules/rxjs/dist/cjs/internal/operators/mergeInternals.js:16:70)
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/filter.js:9:162
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at QueueAction.<anonymous> (/app/node_modules/rxjs/dist/cjs/internal/operators/observeOn.js:9:174)
at QueueAction.AsyncAction._execute (/app/node_modules/rxjs/dist/cjs/internal/scheduler/AsyncAction.js:76:18)
at QueueAction.execute (/app/node_modules/rxjs/dist/cjs/internal/scheduler/QueueAction.js:41:18)
at QueueScheduler.AsyncScheduler.flush (/app/node_modules/rxjs/dist/cjs/internal/scheduler/AsyncScheduler.js:39:33)
at QueueAction.schedule (/app/node_modules/rxjs/dist/cjs/internal/scheduler/QueueAction.js:35:24)
at QueueScheduler.Scheduler.schedule (/app/node_modules/rxjs/dist/cjs/internal/Scheduler.js:13:57)
at /app/node_modules/rxjs/dist/cjs/internal/operators/observeOn.js:9:133
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/mergeInternals.js:27:28
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/mergeInternals.js:27:28
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/mergeInternals.js:27:28
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/switchMap.js:17:185
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/mergeInternals.js:27:28
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at /app/node_modules/rxjs/dist/cjs/internal/operators/map.js:10:24
at OperatorSubscriber._this._next (/app/node_modules/rxjs/dist/cjs/internal/operators/OperatorSubscriber.js:28:21)
at OperatorSubscriber.Subscriber.next (/app/node_modules/rxjs/dist/cjs/internal/Subscriber.js:72:18)
at AsyncAction.<anonymous> (/app/node_modules/rxjs/dist/cjs/internal/observable/timer.js:28:28)
at AsyncAction._execute (/app/node_modules/rxjs/dist/cjs/internal/scheduler/AsyncAction.js:76:18)
at AsyncAction.execute (/app/node_modules/rxjs/dist/cjs/internal/scheduler/AsyncAction.js:64:26)
at AsyncScheduler.flush (/app/node_modules/rxjs/dist/cjs/internal/scheduler/AsyncScheduler.js:39:33)
at listOnTimeout (node:internal/timers:557:17)
at processTimers (node:internal/timers:500:7)
The code
https://github.com/wechaty/wechaty-redux/blob/main/src/duck/rx-async.ts