Class RemoteActor<M, R>

constructor

• new RemoteActor<M, R = void>(
      transport: Transport,
      options?: RemoteOptions,
  ): RemoteActor<M, R>

  Type Parameters

  • M
  • R = void

  Parameters

  • transport: Transport
  • options: RemoteOptions = {}

  Returns RemoteActor<M, R>

Optional Readonlyname

closed

• get closed(): boolean

  Returns boolean

pending

• get pending(): number

  Number of asks awaiting a reply.

  Returns number

ask

• ask(message: M, options?: AskOptions): Promise<R>

  Posts a message and resolves with the remote handler's reply.

  Parameters

  • message: M
  • options: AskOptions = {}

  Returns Promise<R>

close

• close(reason?: unknown): void

  Stops listening and rejects every pending ask with a RemoteError (code: 'closed').

  Parameters

  • reason: unknown = ...

  Returns void

send

• send(message: M): Promise<void>

  Posts a message. Resolves once the transport has accepted it; delivery is not acknowledged.

  Parameters

  • message: M

  Returns Promise<void>