@@ -7,10 +7,7 @@ import { assertUnreachable } from "@/common/utils";
77import * as cbor from "cbor-x" ;
88import * as errors from "./errors" ;
99import { logger } from "./log" ;
10- import {
11- type WebSocketMessage as ConnMessage ,
12- messageLength ,
13- } from "./utils" ;
10+ import { type WebSocketMessage as ConnMessage , messageLength } from "./utils" ;
1411import { ACTOR_HANDLES_SYMBOL , ClientRaw , DynamicImports } from "./client" ;
1512import { ActorDefinition , AnyActorDefinition } from "@/actor/definition" ;
1613import pRetry from "p-retry" ;
@@ -37,9 +34,7 @@ interface SendOpts {
3734 ephemeral : boolean ;
3835}
3936
40- export type ConnTransport =
41- | { websocket : WebSocket }
42- | { sse : EventSource } ;
37+ export type ConnTransport = { websocket : WebSocket } | { sse : EventSource } ;
4338
4439export const CONNECT_SYMBOL = Symbol ( "connect" ) ;
4540
@@ -724,11 +719,15 @@ enc
724719 }
725720}
726721
727- type ExtractActorDefinitionRpcs < AD extends AnyActorDefinition > = AD extends ActorDefinition < any , any , any , any , infer R > ? R : never ;
722+ type ExtractActorDefinitionRpcs < AD extends AnyActorDefinition > =
723+ AD extends ActorDefinition < any , any , any , any , infer R > ? R : never ;
728724
729- type ActorDefinitionRpcs < AD extends AnyActorDefinition > =
730- {
731- [ K in keyof ExtractActorDefinitionRpcs < AD > ] : ExtractActorDefinitionRpcs < AD > [ K ] extends ( ...args : infer Args ) => infer Return ? ActorRPCFunction < Args , Return > : never ;
725+ type ActorDefinitionRpcs < AD extends AnyActorDefinition > = {
726+ [ K in keyof ExtractActorDefinitionRpcs < AD > ] : ExtractActorDefinitionRpcs < AD > [ K ] extends (
727+ ...args : infer Args
728+ ) => infer Return
729+ ? ActorRPCFunction < Args , Return >
730+ : never ;
732731} ;
733732
734733/**
@@ -747,7 +746,8 @@ type ActorDefinitionRpcs<AD extends AnyActorDefinition> =
747746 * @see {@link ActorHandleRaw }
748747 */
749748
750- export type ActorHandle < AD extends AnyActorDefinition > = ActorHandleRaw & ActorDefinitionRpcs < AD > ;
749+ export type ActorHandle < AD extends AnyActorDefinition > = ActorHandleRaw &
750+ ActorDefinitionRpcs < AD > ;
751751
752752//{
753753// [K in keyof A as K extends string ? K extends `_${string}` ? never : K : K]: A[K] extends (...args: infer Args) => infer Return ? ActorRPCFunction<Args, Return> : never;
@@ -764,8 +764,7 @@ export type ActorHandle<AD extends AnyActorDefinition> = ActorHandleRaw & ActorD
764764
765765export type ActorRPCFunction <
766766 Args extends Array < unknown > = unknown [ ] ,
767- Response = unknown
767+ Response = unknown ,
768768> = (
769769 ...args : Args extends [ unknown , ...infer Rest ] ? Rest : Args
770770) => Promise < Response > ;
771-
0 commit comments