import { ActionFunction, ActorRef, ActorRefFrom, ActorRefFromLogic, AnyActorLogic, AnyActorRef, AnyEventObject, CallbackActorLogic, ConditionalRequired, DoneStateEvent, EventObject, GetConcreteByKey, InputFrom, IsNotNever, MachineSnapshot, MetaObject, NonReducibleUnknown, ObservableActorLogic, RequiredActorOptions, RequiredLogicInput, StateMachine, StateValue, Values, } from 'xstate' /** * @public */ export declare interface BufferAddedEmitEvent { type: 'buffer.added' message: TMessage } /** * @public */ export declare interface BufferFlushedEmitEvent { type: 'buffer.flushed' messages: TMessage[] } /** * @public */ export declare type ChannelInput = Omit /** * @public */ export declare interface ChannelInstance { on: < TType extends TReceives['type'], TMessage extends Extract< TReceives, { type: TType } >, >( type: TType, handler: (data: TMessage['data']) => Promise | TMessage['response'], ) => () => void onInternalEvent: < TType extends InternalEmitEvent['type'], TEvent extends Extract< InternalEmitEvent, { type: TType } >, >( type: TType, handler: (event: TEvent) => void, ) => () => void onStatus: (handler: (event: StatusEvent) => void) => void post: < TType extends TSends['type'], TMessage extends Extract< TSends, { type: TType } >, >( ...params: (TMessage['data'] extends undefined ? [TType] : never) | [TType, TMessage['data']] ) => void start: () => () => void stop: () => void } /** * @public */ export declare type Connection< TSends extends Message = Message, TReceives extends Message = Message, > = { actor: ConnectionActor connect: () => void disconnect: () => void id: string name: string machine: ReturnType> on: < TType extends TReceives['type'], TMessage extends Extract< TReceives, { type: TType } >, >( type: TType, handler: (data: TMessage['data']) => Promise | TMessage['response'], ) => () => void onStatus: (handler: (status: Status) => void, filter?: Status) => () => void post: < TType extends TSends['type'], TMessage extends Extract< TSends, { type: TType } >, >( ...params: (TMessage['data'] extends undefined ? [TType] : never) | [TType, TMessage['data']] ) => void setTarget: (target: MessageEventSource) => void start: () => () => void stop: () => void target: MessageEventSource | undefined } /** * @public */ export declare type ConnectionActor< TSends extends Message, TReceives extends Message, > = ActorRefFrom>> /** * @public */ export declare type ConnectionActorLogic< TSends extends Message, TReceives extends Message, > = ReturnType> /** * @public */ export declare interface ConnectionInput { connectTo: string domain?: string heartbeat?: boolean name: string id?: string target?: MessageEventSource targetOrigin: string } /** * @public */ export declare interface Controller { addTarget: (target: MessageEventSource) => () => void createChannel: ( input: ChannelInput, machine?: ConnectionActorLogic, ) => ChannelInstance destroy: () => void } /** * @public */ export declare const createConnection: ( input: ConnectionInput, machine?: ConnectionActorLogic, ) => Connection /** * @public */ export declare const createConnectionMachine: < TSends extends Message, TReceives extends Message, TSendsWithoutResponse extends WithoutResponse = WithoutResponse, >() => StateMachine< { buffer: Array channelId: string connectTo: string domain: string heartbeat: boolean id: string name: string requests: Array> target: MessageEventSource | undefined targetOrigin: string }, | { type: 'connect' } | { type: 'disconnect' } | { type: 'message.received' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse } | { type: 'response' respondTo: string data: Pick } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] } | { type: 'syn' } | { type: 'target.set' target: MessageEventSource }, { [x: string]: | ActorRefFromLogic< StateMachine< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, { 'listen for response'?: | ActorRefFromLogic< ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > > | undefined }, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, Values<{ 'send message': { type: 'send message' params: { message: ProtocolMessage } } 'on success': { type: 'on success' params: NonReducibleUnknown } 'on fail': { type: 'on fail' params: NonReducibleUnknown } 'on abort': { type: 'on abort' params: NonReducibleUnknown } }>, { type: 'expectsResponse' params: unknown }, 'initialTimeout' | 'responseTimeout', 'idle' | 'sending' | 'awaiting' | 'success' | 'aborted' | 'failed', string, { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] }, { requestId: string response: TSends['response'] | null responseTo: string | undefined }, | { type: 'request.failed' requestId: string } | { type: 'request.aborted' requestId: string } | { type: 'request.success' requestId: string response: MessageData | null responseTo: string | undefined }, MetaObject, { readonly context: ({ input, }: { spawn: { ( logic: TSrc, ...[options]: { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } extends infer T ? T extends { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } ? T extends { src: TSrc } ? ConditionalRequired< [ options?: | ({ id?: T['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never ): ActorRefFromLogic< GetConcreteByKey< { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, 'src', TSrc >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { channelId: string data: TSends['data'] | undefined domain: string expectResponse: boolean from: string id: string parentRef: AnyActorRef resolvable: PromiseWithResolvers | undefined response: null responseTimeout: number | undefined responseTo: string | undefined signal: AbortSignal | undefined sources: Set suppressWarnings: boolean | undefined targetOrigin: string to: string type: TSends['type'] } readonly initial: 'idle' readonly on: { readonly abort: '.aborted' } readonly states: { readonly idle: { readonly after: { readonly initialTimeout: readonly [ { readonly target: 'sending' }, ] } } readonly sending: { readonly entry: { readonly type: 'send message' readonly params: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } }) => { message: { channelId: string data: MessageData domain: string from: string id: string to: string type: string responseTo: string | undefined } } } readonly always: readonly [ { readonly guard: 'expectsResponse' readonly target: 'awaiting' }, 'success', ] } readonly awaiting: { readonly invoke: { readonly id: 'listen for response' readonly src: 'listen' readonly input: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string sources: Set signal: AbortSignal | undefined } readonly onError: 'aborted' } readonly after: { readonly responseTimeout: 'failed' } readonly on: { readonly message: { readonly actions: ActionFunction< RequestMachineContext, { type: 'message' data: ProtocolMessage }, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, undefined, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, never, never, never, never > readonly target: 'success' } } } readonly failed: { readonly type: 'final' readonly entry: 'on fail' } readonly success: { readonly type: 'final' readonly entry: 'on success' } readonly aborted: { readonly type: 'final' readonly entry: 'on abort' } } readonly output: ({ context, self, }: { context: RequestMachineContext event: DoneStateEvent self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string response: TSends['response'] | null responseTo: string | undefined } } > > | ActorRefFromLogic< ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > > | ActorRefFromLogic< CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > > | undefined 'listen for handshake'?: | ActorRefFromLogic< ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > > | undefined 'listen for messages'?: | ActorRefFromLogic< ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > > | undefined 'send heartbeat'?: | ActorRefFromLogic< CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > > | undefined 'send syn'?: | ActorRefFromLogic< CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > > | undefined }, Values<{ listen: { src: 'listen' logic: ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > id: 'listen for handshake' | 'listen for messages' } sendBackAtInterval: { src: 'sendBackAtInterval' logic: CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > id: 'send heartbeat' | 'send syn' } requestMachine: { src: 'requestMachine' logic: StateMachine< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, { 'listen for response'?: | ActorRefFromLogic< ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > > | undefined }, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, Values<{ 'send message': { type: 'send message' params: { message: ProtocolMessage } } 'on success': { type: 'on success' params: NonReducibleUnknown } 'on fail': { type: 'on fail' params: NonReducibleUnknown } 'on abort': { type: 'on abort' params: NonReducibleUnknown } }>, { type: 'expectsResponse' params: unknown }, 'initialTimeout' | 'responseTimeout', 'idle' | 'sending' | 'awaiting' | 'success' | 'aborted' | 'failed', string, { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] }, { requestId: string response: TSends['response'] | null responseTo: string | undefined }, | { type: 'request.failed' requestId: string } | { type: 'request.aborted' requestId: string } | { type: 'request.success' requestId: string response: MessageData | null responseTo: string | undefined }, MetaObject, { readonly context: ({ input, }: { spawn: { ( logic: TSrc, ...[options]: { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } extends infer T ? T extends { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } ? T extends { src: TSrc } ? ConditionalRequired< [ options?: | ({ id?: T['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never ): ActorRefFromLogic< GetConcreteByKey< { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, 'src', TSrc >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { channelId: string data: TSends['data'] | undefined domain: string expectResponse: boolean from: string id: string parentRef: AnyActorRef resolvable: PromiseWithResolvers | undefined response: null responseTimeout: number | undefined responseTo: string | undefined signal: AbortSignal | undefined sources: Set suppressWarnings: boolean | undefined targetOrigin: string to: string type: TSends['type'] } readonly initial: 'idle' readonly on: { readonly abort: '.aborted' } readonly states: { readonly idle: { readonly after: { readonly initialTimeout: readonly [ { readonly target: 'sending' }, ] } } readonly sending: { readonly entry: { readonly type: 'send message' readonly params: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } }) => { message: { channelId: string data: MessageData domain: string from: string id: string to: string type: string responseTo: string | undefined } } } readonly always: readonly [ { readonly guard: 'expectsResponse' readonly target: 'awaiting' }, 'success', ] } readonly awaiting: { readonly invoke: { readonly id: 'listen for response' readonly src: 'listen' readonly input: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string sources: Set signal: AbortSignal | undefined } readonly onError: 'aborted' } readonly after: { readonly responseTimeout: 'failed' } readonly on: { readonly message: { readonly actions: ActionFunction< RequestMachineContext, { type: 'message' data: ProtocolMessage }, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, undefined, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, never, never, never, never > readonly target: 'success' } } } readonly failed: { readonly type: 'final' readonly entry: 'on fail' } readonly success: { readonly type: 'final' readonly entry: 'on success' } readonly aborted: { readonly type: 'final' readonly entry: 'on abort' } } readonly output: ({ context, self, }: { context: RequestMachineContext event: DoneStateEvent self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string response: TSends['response'] | null responseTo: string | undefined } } > id: string | undefined } }>, Values<{ 'buffer message': { type: 'buffer message' params: NonReducibleUnknown } 'create request': { type: 'create request' params: NonReducibleUnknown } 'emit received message': { type: 'emit received message' params: NonReducibleUnknown } 'emit status': { type: 'emit status' params: { status: Status } } 'post message': { type: 'post message' params: NonReducibleUnknown } 'remove request': { type: 'remove request' params: NonReducibleUnknown } 'respond': { type: 'respond' params: NonReducibleUnknown } 'send handshake ack': { type: 'send handshake ack' params: NonReducibleUnknown } 'send disconnect': { type: 'send disconnect' params: NonReducibleUnknown } 'send handshake syn': { type: 'send handshake syn' params: NonReducibleUnknown } 'send pending messages': { type: 'send pending messages' params: NonReducibleUnknown } 'set target': { type: 'set target' params: NonReducibleUnknown } }>, Values<{ 'has target': { type: 'has target' params: unknown } 'should send heartbeats': { type: 'should send heartbeats' params: unknown } }>, never, | 'idle' | 'handshaking' | 'disconnected' | { connected: { heartbeat: 'sending' | 'checking' } }, string, ConnectionInput, NonReducibleUnknown, | StatusEmitEvent | BufferAddedEmitEvent | BufferFlushedEmitEvent | MessageEmitEvent, MetaObject, { /** @xstate-layout N4IgpgJg5mDOIC5QGMAWBDAdpsAbAxAC7oBOMhAdLGIQNoAMAuoqAA4D2sAloV+5ixAAPRAHZRAJgoAWABz0ArHICMy2QGZZCgJwAaEAE9EE+tIrb6ANgkLl46fTuj1AXxf60WHARJgAjgCucJSwAcjIcLAMzEggHNy8-IIiCKLS2hQS6qb2yurisrL6RgjK9LIyCuqq0g7WstZuHhjYePi+gcEUAGboXLiQ0YLxPHwCsSmiCgoykpayDtqS6trqxYjKEk0gnq24FFwQA-jI-DjIdEzDnKNJExuOZpZ12eq29OrSCuupypYUojUaTKCnm5Wk2123gORzA+HilxibBuiXGoBSGnUAIU4gU9FWamUtR+lmUM1EllBEkslMUEnpkJa0JaEFgGAA1lxMFB8LADJghrERqjkhtshk3mTtNo5OpqpYfqCKhTptoqpY1WUtu4dky8BQWWz0Jzue1-EFYIjrgkxqLSupqRRPpoPqJtLI0hIioZENJJE7NnJ8ZYHVk1YyvPrDRyuTyEYLkTa7uixVlMh81KGFhS1j6EPkZlpVjTphr8mkI3sDVhWTHTQBbSLoGAUXwRLgAN0GVyFKNt91KimUFEKXvKC2s9R+6X+jipnzJeSqEJ1UKjNaNJp5EC4sFOrQuCbifeTwg2cgoym0RPxDtqkj0eaB9Ao8zSolMEivZVcq71+33c5CEgeFOCtXskzRM8EDxKRpmkSw3QJbQsmpH5tHmV8JHSbJpDsakV2aSMALOMALhAjoLXAxNbiglI-SxWw1Vw0QNDw0Qfg9KQ7EJSxHHxApK2hQCyOAiAzVgDhMGoI9hX7FMEHSF8cWkelpHURCbBsb481xAEgT9BQJCmWQsiE-URPI8TG1gWBmzAVsyLATtuyRY9ILtWoKmlL82Kqd0tAVJ91LMHFZDKIkVlkNVZHMkiDzE-Adz3UjDx7GiRQHCKnheD53k+HSSkDDIwpBVTqQwuKKEssSDTAUhCAAI3qyg0DIrd8Fkk86MQUMnVM+RynoegTDJH48hGp0vR-FDRqqKqasgOqGua9AQjATAd1NSiul6fpXOtWi7Wy19cslD4vnG7IX3oVjVDUVYEJQqrksW8SdstLqPKy0wKgG1RhtMWogqKhoMjkWp6XxUyFBe3c3tAz70vco6fq+V8PTkGUFzdQqNnELEM2yClrwwzQ4ZShKQJqr7UYU98AS0W9pT4z5pHG0yXwMkNNTyGk3B1TB2AgOBBDXXBDsyhSFG9EovQqN5i1JeRcKqw4Bkl+ToMx8x0j+EaqQ9XMSkBURMgMkEwQWKro2NWNNdPFJAzN0lJGM4slDxhBEJfXyplBd03wW1KxIdnrBxBh4JAyW75C8rJpmDqmIGWkgmpasPjqUcaHooMLHA0uU1UkJOgKW1B6rT1bWor5At0zgcTAkK7hrz1irB0D8cW0UvRPLyv07WqgNq2qAG+l9SnXUz0UOXD5xuMs3Y4+DVJBX7UiKrV6Q8gcfoJO54rFefLLqfJYX1WKYNLxL4NO1NwgA */ readonly id: 'connection' readonly context: ({ input, }: { spawn: { ( logic: TSrc, ...[options]: | ({ src: 'listen' logic: ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > id: 'listen for handshake' | 'listen for messages' } extends infer T ? T extends { src: 'listen' logic: ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > id: 'listen for handshake' | 'listen for messages' } ? T extends { src: TSrc } ? ConditionalRequired< [ options?: | ({ id?: T['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never) | ({ src: 'sendBackAtInterval' logic: CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > id: 'send heartbeat' | 'send syn' } extends infer T_1 ? T_1 extends { src: 'sendBackAtInterval' logic: CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > id: 'send heartbeat' | 'send syn' } ? T_1 extends { src: TSrc } ? ConditionalRequired< [ options?: | ({ id?: T_1['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_1 in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never) | ({ src: 'requestMachine' logic: StateMachine< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, { 'listen for response'?: | ActorRefFromLogic< ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > > | undefined }, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, Values<{ 'send message': { type: 'send message' params: { message: ProtocolMessage } } 'on success': { type: 'on success' params: NonReducibleUnknown } 'on fail': { type: 'on fail' params: NonReducibleUnknown } 'on abort': { type: 'on abort' params: NonReducibleUnknown } }>, { type: 'expectsResponse' params: unknown }, 'initialTimeout' | 'responseTimeout', 'idle' | 'sending' | 'awaiting' | 'success' | 'aborted' | 'failed', string, { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] }, { requestId: string response: TSends['response'] | null responseTo: string | undefined }, | { type: 'request.failed' requestId: string } | { type: 'request.aborted' requestId: string } | { type: 'request.success' requestId: string response: MessageData | null responseTo: string | undefined }, MetaObject, { readonly context: ({ input, }: { spawn: { ( logic: TSrc_1, ...[options]: { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } extends infer T_2 ? T_2 extends { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } ? T_2 extends { src: TSrc_1 } ? ConditionalRequired< [ options?: | ({ id?: T_2['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_2 in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never ): ActorRefFromLogic< GetConcreteByKey< { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, 'src', TSrc_1 >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_2 in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { channelId: string data: TSends['data'] | undefined domain: string expectResponse: boolean from: string id: string parentRef: AnyActorRef resolvable: PromiseWithResolvers | undefined response: null responseTimeout: number | undefined responseTo: string | undefined signal: AbortSignal | undefined sources: Set suppressWarnings: boolean | undefined targetOrigin: string to: string type: TSends['type'] } readonly initial: 'idle' readonly on: { readonly abort: '.aborted' } readonly states: { readonly idle: { readonly after: { readonly initialTimeout: readonly [ { readonly target: 'sending' }, ] } } readonly sending: { readonly entry: { readonly type: 'send message' readonly params: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } }) => { message: { channelId: string data: MessageData domain: string from: string id: string to: string type: string responseTo: string | undefined } } } readonly always: readonly [ { readonly guard: 'expectsResponse' readonly target: 'awaiting' }, 'success', ] } readonly awaiting: { readonly invoke: { readonly id: 'listen for response' readonly src: 'listen' readonly input: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string sources: Set signal: AbortSignal | undefined } readonly onError: 'aborted' } readonly after: { readonly responseTimeout: 'failed' } readonly on: { readonly message: { readonly actions: ActionFunction< RequestMachineContext, { type: 'message' data: ProtocolMessage }, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, undefined, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, never, never, never, never > readonly target: 'success' } } } readonly failed: { readonly type: 'final' readonly entry: 'on fail' } readonly success: { readonly type: 'final' readonly entry: 'on success' } readonly aborted: { readonly type: 'final' readonly entry: 'on abort' } } readonly output: ({ context, self, }: { context: RequestMachineContext event: DoneStateEvent self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string response: TSends['response'] | null responseTo: string | undefined } } > id: string | undefined } extends infer T_2 ? T_2 extends { src: 'requestMachine' logic: StateMachine< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, { 'listen for response'?: | ActorRefFromLogic< ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > > | undefined }, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, Values<{ 'send message': { type: 'send message' params: { message: ProtocolMessage } } 'on success': { type: 'on success' params: NonReducibleUnknown } 'on fail': { type: 'on fail' params: NonReducibleUnknown } 'on abort': { type: 'on abort' params: NonReducibleUnknown } }>, { type: 'expectsResponse' params: unknown }, 'initialTimeout' | 'responseTimeout', 'idle' | 'sending' | 'awaiting' | 'success' | 'aborted' | 'failed', string, { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] }, { requestId: string response: TSends['response'] | null responseTo: string | undefined }, | { type: 'request.failed' requestId: string } | { type: 'request.aborted' requestId: string } | { type: 'request.success' requestId: string response: MessageData | null responseTo: string | undefined }, MetaObject, { readonly context: ({ input, }: { spawn: { ( logic: TSrc_1, ...[options]: { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } extends infer T_3 ? T_3 extends { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } ? T_3 extends { src: TSrc_1 } ? ConditionalRequired< [ options?: | ({ id?: T_3['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_3 in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never ): ActorRefFromLogic< GetConcreteByKey< { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, 'src', TSrc_1 >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_3 in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { channelId: string data: TSends['data'] | undefined domain: string expectResponse: boolean from: string id: string parentRef: AnyActorRef resolvable: PromiseWithResolvers | undefined response: null responseTimeout: number | undefined responseTo: string | undefined signal: AbortSignal | undefined sources: Set suppressWarnings: boolean | undefined targetOrigin: string to: string type: TSends['type'] } readonly initial: 'idle' readonly on: { readonly abort: '.aborted' } readonly states: { readonly idle: { readonly after: { readonly initialTimeout: readonly [ { readonly target: 'sending' }, ] } } readonly sending: { readonly entry: { readonly type: 'send message' readonly params: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } }) => { message: { channelId: string data: MessageData domain: string from: string id: string to: string type: string responseTo: string | undefined } } } readonly always: readonly [ { readonly guard: 'expectsResponse' readonly target: 'awaiting' }, 'success', ] } readonly awaiting: { readonly invoke: { readonly id: 'listen for response' readonly src: 'listen' readonly input: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string sources: Set signal: AbortSignal | undefined } readonly onError: 'aborted' } readonly after: { readonly responseTimeout: 'failed' } readonly on: { readonly message: { readonly actions: ActionFunction< RequestMachineContext, { type: 'message' data: ProtocolMessage }, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, undefined, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, never, never, never, never > readonly target: 'success' } } } readonly failed: { readonly type: 'final' readonly entry: 'on fail' } readonly success: { readonly type: 'final' readonly entry: 'on success' } readonly aborted: { readonly type: 'final' readonly entry: 'on abort' } } readonly output: ({ context, self, }: { context: RequestMachineContext event: DoneStateEvent self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string response: TSends['response'] | null responseTo: string | undefined } } > id: string | undefined } ? T_2 extends { src: TSrc } ? ConditionalRequired< [ options?: | ({ id?: T_2['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_2 in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never) ): ActorRefFromLogic< GetConcreteByKey< Values<{ listen: { src: 'listen' logic: ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > id: 'listen for handshake' | 'listen for messages' } sendBackAtInterval: { src: 'sendBackAtInterval' logic: CallbackActorLogic< EventObject, { event: EventObject immediate?: boolean interval: number }, EventObject > id: 'send heartbeat' | 'send syn' } requestMachine: { src: 'requestMachine' logic: StateMachine< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, { 'listen for response'?: | ActorRefFromLogic< ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > > | undefined }, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, Values<{ 'send message': { type: 'send message' params: { message: ProtocolMessage } } 'on success': { type: 'on success' params: NonReducibleUnknown } 'on fail': { type: 'on fail' params: NonReducibleUnknown } 'on abort': { type: 'on abort' params: NonReducibleUnknown } }>, { type: 'expectsResponse' params: unknown }, 'initialTimeout' | 'responseTimeout', 'idle' | 'sending' | 'awaiting' | 'success' | 'aborted' | 'failed', string, { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] }, { requestId: string response: TSends['response'] | null responseTo: string | undefined }, | { type: 'request.failed' requestId: string } | { type: 'request.aborted' requestId: string } | { type: 'request.success' requestId: string response: MessageData | null responseTo: string | undefined }, MetaObject, { readonly context: ({ input, }: { spawn: { ( logic: TSrc_1, ...[options]: { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } extends infer T_3 ? T_3 extends { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } ? T_3 extends { src: TSrc_1 } ? ConditionalRequired< [ options?: | ({ id?: T_3['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_3 in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never ): ActorRefFromLogic< GetConcreteByKey< { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, 'src', TSrc_1 >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K_3 in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { channelId: string data: TSends['data'] | undefined domain: string expectResponse: boolean from: string id: string parentRef: AnyActorRef resolvable: PromiseWithResolvers | undefined response: null responseTimeout: number | undefined responseTo: string | undefined signal: AbortSignal | undefined sources: Set suppressWarnings: boolean | undefined targetOrigin: string to: string type: TSends['type'] } readonly initial: 'idle' readonly on: { readonly abort: '.aborted' } readonly states: { readonly idle: { readonly after: { readonly initialTimeout: readonly [ { readonly target: 'sending' }, ] } } readonly sending: { readonly entry: { readonly type: 'send message' readonly params: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } }) => { message: { channelId: string data: MessageData domain: string from: string id: string to: string type: string responseTo: string | undefined } } } readonly always: readonly [ { readonly guard: 'expectsResponse' readonly target: 'awaiting' }, 'success', ] } readonly awaiting: { readonly invoke: { readonly id: 'listen for response' readonly src: 'listen' readonly input: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string sources: Set signal: AbortSignal | undefined } readonly onError: 'aborted' } readonly after: { readonly responseTimeout: 'failed' } readonly on: { readonly message: { readonly actions: ActionFunction< RequestMachineContext, { type: 'message' data: ProtocolMessage }, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, undefined, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, never, never, never, never > readonly target: 'success' } } } readonly failed: { readonly type: 'final' readonly entry: 'on fail' } readonly success: { readonly type: 'final' readonly entry: 'on success' } readonly aborted: { readonly type: 'final' readonly entry: 'on abort' } } readonly output: ({ context, self, }: { context: RequestMachineContext event: DoneStateEvent self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string response: TSends['response'] | null responseTo: string | undefined } } > id: string | undefined } }>, 'src', TSrc >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: ConnectionInput self: ActorRef< MachineSnapshot< { buffer: Array channelId: string connectTo: string domain: string heartbeat: boolean id: string name: string requests: Array> target: MessageEventSource | undefined targetOrigin: string }, | { type: 'connect' } | { type: 'disconnect' } | { type: 'message.received' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse } | { type: 'response' respondTo: string data: Pick } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] } | { type: 'syn' } | { type: 'target.set' target: MessageEventSource }, Record, StateValue, string, unknown, any, any >, | { type: 'connect' } | { type: 'disconnect' } | { type: 'message.received' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse } | { type: 'response' respondTo: string data: Pick } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] } | { type: 'syn' } | { type: 'target.set' target: MessageEventSource }, AnyEventObject > }) => { id: string buffer: never[] channelId: string connectTo: string domain: string heartbeat: boolean name: string requests: never[] target: MessageEventSource | undefined targetOrigin: string } readonly on: { readonly 'target.set': { readonly actions: 'set target' } readonly 'request.success': { readonly actions: 'remove request' } readonly 'request.failed': { readonly actions: 'remove request' } } readonly initial: 'idle' readonly states: { readonly idle: { readonly entry: readonly [ { readonly type: 'emit status' readonly params: { readonly status: 'idle' } }, ] readonly on: { readonly connect: { readonly target: 'handshaking' readonly guard: 'has target' } readonly post: { readonly actions: 'buffer message' } } } readonly handshaking: { readonly id: 'handshaking' readonly entry: readonly [ { readonly type: 'emit status' readonly params: { readonly status: 'handshaking' } }, ] readonly invoke: readonly [ { readonly id: 'send syn' readonly src: 'sendBackAtInterval' readonly input: () => { event: { type: string } interval: number immediate: true } }, { readonly id: 'listen for handshake' readonly src: 'listen' readonly input: (input: { context: { buffer: Array channelId: string connectTo: string domain: string heartbeat: boolean id: string name: string requests: Array> target: MessageEventSource | undefined targetOrigin: string } event: | { type: 'connect' } | { type: 'disconnect' } | { type: 'message.received' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse } | { type: 'response' respondTo: string data: Pick } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] } | { type: 'syn' } | { type: 'target.set' target: MessageEventSource } self: ActorRef< MachineSnapshot< { buffer: Array channelId: string connectTo: string domain: string heartbeat: boolean id: string name: string requests: Array> target: MessageEventSource | undefined targetOrigin: string }, | { type: 'connect' } | { type: 'disconnect' } | { type: 'message.received' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse } | { type: 'response' respondTo: string data: Pick } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] } | { type: 'syn' } | { type: 'target.set' target: MessageEventSource }, Record, StateValue, string, unknown, any, any >, | { type: 'connect' } | { type: 'disconnect' } | { type: 'message.received' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse } | { type: 'response' respondTo: string data: Pick } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] } | { type: 'syn' } | { type: 'target.set' target: MessageEventSource }, AnyEventObject > }) => ListenInput }, ] readonly on: { readonly 'syn': { readonly actions: 'send handshake syn' } readonly 'request': { readonly actions: 'create request' } readonly 'post': { readonly actions: 'buffer message' } readonly 'message.received': { readonly target: 'connected' } readonly 'disconnect': { readonly target: 'disconnected' } } readonly exit: 'send handshake ack' } readonly connected: { readonly entry: readonly [ 'send pending messages', { readonly type: 'emit status' readonly params: { readonly status: 'connected' } }, ] readonly invoke: { readonly id: 'listen for messages' readonly src: 'listen' readonly input: < TContext extends { domain: string connectTo: string name: string target: MessageEventSource | undefined }, >({ context, }: { context: TContext }) => ListenInput } readonly on: { readonly 'post': { readonly actions: 'post message' } readonly 'request': { readonly actions: 'create request' } readonly 'response': { readonly actions: 'respond' } readonly 'message.received': { readonly actions: 'emit received message' } readonly 'disconnect': { readonly target: 'disconnected' } } readonly initial: 'heartbeat' readonly states: { readonly heartbeat: { readonly initial: 'checking' readonly states: { readonly checking: { readonly always: { readonly guard: 'should send heartbeats' readonly target: 'sending' } } readonly sending: { readonly on: { readonly 'request.failed': { readonly target: '#handshaking' } } readonly invoke: { readonly id: 'send heartbeat' readonly src: 'sendBackAtInterval' readonly input: () => { event: { type: string data: { type: string data: undefined } } interval: number immediate: false } } } } } } } readonly disconnected: { readonly id: 'disconnected' readonly entry: readonly [ 'send disconnect', { readonly type: 'emit status' readonly params: { readonly status: 'disconnected' } }, ] readonly on: { readonly request: { readonly actions: 'create request' } readonly post: { readonly actions: 'buffer message' } readonly connect: { readonly target: 'handshaking' readonly guard: 'has target' } } } } } > /** * @public */ export declare const createController: (input: {targetOrigin: string}) => Controller /** * @public */ export declare const createListenLogic: ( compatMap?: (event: MessageEvent) => MessageEvent, ) => ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > /** * @public */ export declare const createNode: ( input: NodeInput, machine?: NodeActorLogic, ) => Node_2 /** * @public */ export declare const createNodeMachine: < TSends extends Message, TReceives extends Message, TSendsWithoutResponse extends WithoutResponse = WithoutResponse, >() => StateMachine< { buffer: Array<{ data: TSendsWithoutResponse resolvable?: PromiseWithResolvers options?: { signal?: AbortSignal suppressWarnings?: boolean } }> channelId: string | null connectTo: string domain: string handshakeBuffer: Array<{ type: 'message.received' message: MessageEvent> }> name: string requests: Array> target: MessageEventSource | undefined targetOrigin: string | null }, | { type: 'heartbeat.received' message: MessageEvent> } | { type: 'message.received' message: MessageEvent> } | { type: 'handshake.syn' message: MessageEvent> } | { type: 'post' data: TSendsWithoutResponse resolvable?: PromiseWithResolvers options?: { responseTimeout?: number signal?: AbortSignal suppressWarnings?: boolean } } | { type: 'request.aborted' requestId: string } | { type: 'request.failed' requestId: string } | { type: 'request.success' requestId: string response: TSends['response'] | null responseTo: string | undefined } | { type: 'request' data: RequestData | RequestData[] }, { [x: string]: | ActorRefFromLogic< ObservableActorLogic< { type: string message: MessageEvent }, ListenInput, EventObject > > | ActorRefFromLogic< StateMachine< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, { 'listen for response'?: | ActorRefFromLogic< ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > > | undefined }, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, Values<{ 'send message': { type: 'send message' params: { message: ProtocolMessage } } 'on success': { type: 'on success' params: NonReducibleUnknown } 'on fail': { type: 'on fail' params: NonReducibleUnknown } 'on abort': { type: 'on abort' params: NonReducibleUnknown } }>, { type: 'expectsResponse' params: unknown }, 'initialTimeout' | 'responseTimeout', 'idle' | 'sending' | 'awaiting' | 'success' | 'aborted' | 'failed', string, { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] }, { requestId: string response: TSends['response'] | null responseTo: string | undefined }, | { type: 'request.failed' requestId: string } | { type: 'request.aborted' requestId: string } | { type: 'request.success' requestId: string response: MessageData | null responseTo: string | undefined }, MetaObject, { readonly context: ({ input, }: { spawn: { ( logic: TSrc, ...[options]: { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } extends infer T ? T extends { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' } ? T extends { src: TSrc } ? ConditionalRequired< [ options?: | ({ id?: T['id'] | undefined systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredActorOptions]: unknown}) | undefined, ], IsNotNever> > : never : never : never ): ActorRefFromLogic< GetConcreteByKey< { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, 'src', TSrc >['logic'] > ( src: TLogic, ...[options]: ConditionalRequired< [ options?: | ({ id?: never systemId?: string input?: InputFrom | undefined syncSnapshot?: boolean } & {[K in RequiredLogicInput]: unknown}) | undefined, ], IsNotNever> > ): ActorRefFromLogic } input: { channelId: string data?: TSends['data'] | undefined domain: string expectResponse?: boolean from: string parentRef: AnyActorRef resolvable?: PromiseWithResolvers | undefined responseTimeout?: number responseTo?: string signal?: AbortSignal sources: Set | MessageEventSource suppressWarnings?: boolean targetOrigin: string to: string type: TSends['type'] } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { channelId: string data: TSends['data'] | undefined domain: string expectResponse: boolean from: string id: string parentRef: AnyActorRef resolvable: PromiseWithResolvers | undefined response: null responseTimeout: number | undefined responseTo: string | undefined signal: AbortSignal | undefined sources: Set suppressWarnings: boolean | undefined targetOrigin: string to: string type: TSends['type'] } readonly initial: 'idle' readonly on: { readonly abort: '.aborted' } readonly states: { readonly idle: { readonly after: { readonly initialTimeout: readonly [ { readonly target: 'sending' }, ] } } readonly sending: { readonly entry: { readonly type: 'send message' readonly params: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } }) => { message: { channelId: string data: MessageData domain: string from: string id: string to: string type: string responseTo: string | undefined } } } readonly always: readonly [ { readonly guard: 'expectsResponse' readonly target: 'awaiting' }, 'success', ] } readonly awaiting: { readonly invoke: { readonly id: 'listen for response' readonly src: 'listen' readonly input: ({ context, }: { context: RequestMachineContext event: | { type: 'message' data: ProtocolMessage } | { type: 'abort' } self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, Record, StateValue, string, unknown, any, any >, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, AnyEventObject > }) => { requestId: string sources: Set signal: AbortSignal | undefined } readonly onError: 'aborted' } readonly after: { readonly responseTimeout: 'failed' } readonly on: { readonly message: { readonly actions: ActionFunction< RequestMachineContext, { type: 'message' data: ProtocolMessage }, | { type: 'message' data: ProtocolMessage } | { type: 'abort' }, undefined, { src: 'listen' logic: ObservableActorLogic< MessageEvent>, { requestId: string sources: Set signal?: AbortSignal }, EventObject > id: 'listen for response' }, never, never, never, never > readonly target: 'success' } } } readonly failed: { readonly type: 'final' readonly entry: 'on fail' } readonly success: { readonly type: 'final' readonly entry: 'on success' } readonly aborted: { readonly type: 'final' readonly entry: 'on abort' } } readonly output: ({ context, self, }: { context: RequestMachineContext event: DoneStateEvent self: ActorRef< MachineSnapshot< RequestMachineContext, | { type: 'message' data: ProtocolMessage