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

    Function BidiStream

    Mark a method as a bidirectional-streaming RPC.

    • Mark a method as a bidirectional-streaming RPC.

      Parameters

      • Optionaloptions: RpcOptions

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

      @BidiStream()
      async *chat(requests: AsyncIterable<Message>): AsyncGenerator<Message> { ... }