nestjs - 如何从 nestjs saga 发出多个命令？

Question

我创建了一个 saga 来对给定的事件使用react。在这种情况下，需要发出多个命令。

我的 Saga 看起来像这样:

@Injectable()
export class SomeSagas {
    public constructor() {}

    onSomeEvent(events$: EventObservable<any>): Observable<ICommand> {
        return events$.ofType(SomeEvent).pipe(
            map((event: SomeEvent) => {
                return of(new SomeCommand(uuid()), new SomeCommand(uuid()));
            }),
        );
    }
}

调试时我发现有一个错误抛出'CommandHandler not found exception!'，这有点令人困惑，因为万一我只返回一个 SomeCommand 实例。命令处理程序被正确调用。

我错过了什么还是传奇实现不支持发出多个命令？

Answer 1

似乎我找到了答案 - 它与 RxJS 相关:

@Injectable()
export class SomeSagas {
    public constructor() {}

    onSomeEvent(events$: EventObservable<any>): Observable<ICommand> {
        return events$.ofType(SomeEvent).pipe(
            map((event: SomeEvent) => {
                const commands: ICommand[] = [
                  new SomeCommand(uuid()),
                  new SomeCommand(uuid()),
                  new SomeCommand(uuid()),
                ];
                return commands;
            }),
            flatMap(c => c), // piping to flatMap RxJS operator is solving the issue I had
        );
    }
}