@aster-rpc/aster API Reference
    Preparing search index...

    Function ServerStream

    Mark a method as a server-streaming RPC (returns AsyncGenerator).

    • Mark a method as a server-streaming RPC (single request, multiple responses). Method must be an async generator.

      Parameters

      • Optionaloptions: RpcOptions

      Returns <T extends (...args: any[]) => any>(
          target: T,
          _context: ClassMethodDecoratorContext,
      ) => T

      @ServerStream()
      async *watchUpdates(req: WatchRequest): AsyncGenerator<Update> { ... }