Method getMany

sample/04-grpc/src/hero/hero.controller.ts:32–40

()

  @Get()
  getMany(): Observable<Hero[]> {
    const ids$ = new ReplaySubject<HeroById>();
    ids$.next({ id: 1 });
    ids$.next({ id: 2 });
    ids$.complete();

    const stream = this.heroesService.findMany(ids$.asObservable());
    return stream.pipe(toArray());
  }

  @Get(class="st">':id')
  getById(@Param(class="st">'id') id: string): Observable<Hero> {