Skip to content

SharedWorkerRequest

Defined in: packages/@livestore/adapter-web/src/web-worker/common/worker-schema.ts:208

  • Variance<CreateConnection | LeaderWorkerInnerBootStatusStream | LeaderWorkerInnerPushToLeader | LeaderWorkerInnerPullStream | LeaderWorkerInnerExport | LeaderWorkerInnerExportEventlog | LeaderWorkerInnerGetRecreateSnapshot | LeaderWorkerInnerGetLeaderHead | LeaderWorkerInnerGetLeaderSyncState | LeaderWorkerInnerShutdown | LeaderWorkerInnerExtraDevtoolsMessage | SharedWorkerInitialMessage | SharedWorkerUpdateMessagePort, { _tag: "DevtoolsWebCommon.CreateConnection"; from: string; port: MessagePort; } | { _tag: "BootStatusStream"; } | { _tag: "PushToLeader"; batch: readonly object[]; } | { _tag: "PullStream"; cursor: { client: number; global: number; rebaseGeneration: number; }; } | { _tag: "Export"; } | { _tag: "ExportEventlog"; } | { _tag: "GetRecreateSnapshot"; } | { _tag: "GetLeaderHead"; } | { _tag: "GetLeaderSyncState"; } | { _tag: "Shutdown"; } | { _tag: "ExtraDevtoolsMessage"; message: { _tag: "LSD.Leader.SnapshotReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.EventlogReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.NetworkStatusSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.NetworkStatusUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.Disconnect"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.CommitEventReq"; clientId: string; eventEncoded: { args: any; name: string; }; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.Ping"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.DatabaseFileInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHistorySubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHistoryUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncingInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHeadSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHeadUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.LoadDatabaseFile.Request"; clientId: string; data: Uint8Array<ArrayBufferLike>; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.ResetAllData.Request"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; mode: "all-data" | "only-app-db"; requestId: string; } | { _tag: "LSD.Leader.SetSyncLatch.Request"; clientId: string; closeLatch: boolean; liveStoreVersion: "0.3.2-dev.11"; requestId: string; }; } | { _tag: "InitialMessage"; liveStoreVersion: "0.3.2-dev.11"; payload: { _tag: "FromClientSession"; initialMessage: { _tag: "InitialMessage"; clientId: string; debugInstanceId: string; devtoolsEnabled: boolean; storageOptions: { directory?: string; type: "opfs"; }; storeId: string; syncPayload: undefined | JsonValue; }; } | { _tag: "FromWebBridge"; }; } | { _tag: "UpdateMessagePort"; port: MessagePort; }, never, this>

new SharedWorkerRequest(_): SharedWorkerRequest

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:83

never

SharedWorkerRequest

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).constructor

readonly [TypeId]: object

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:160

readonly _A: Invariant<CreateConnection | LeaderWorkerInnerBootStatusStream | LeaderWorkerInnerPushToLeader | LeaderWorkerInnerPullStream | LeaderWorkerInnerExport | LeaderWorkerInnerExportEventlog | LeaderWorkerInnerGetRecreateSnapshot | LeaderWorkerInnerGetLeaderHead | LeaderWorkerInnerGetLeaderSyncState | LeaderWorkerInnerShutdown | LeaderWorkerInnerExtraDevtoolsMessage | SharedWorkerInitialMessage | SharedWorkerUpdateMessagePort>

readonly _I: Invariant<{ _tag: "DevtoolsWebCommon.CreateConnection"; from: string; port: MessagePort; } | { _tag: "BootStatusStream"; } | { _tag: "PushToLeader"; batch: readonly object[]; } | { _tag: "PullStream"; cursor: { client: number; global: number; rebaseGeneration: number; }; } | { _tag: "Export"; } | { _tag: "ExportEventlog"; } | { _tag: "GetRecreateSnapshot"; } | { _tag: "GetLeaderHead"; } | { _tag: "GetLeaderSyncState"; } | { _tag: "Shutdown"; } | { _tag: "ExtraDevtoolsMessage"; message: { _tag: "LSD.Leader.SnapshotReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.EventlogReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.NetworkStatusSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.NetworkStatusUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.Disconnect"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.CommitEventReq"; clientId: string; eventEncoded: { args: any; name: string; }; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.Ping"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.DatabaseFileInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHistorySubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHistoryUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncingInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHeadSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHeadUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.LoadDatabaseFile.Request"; clientId: string; data: Uint8Array<ArrayBufferLike>; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.ResetAllData.Request"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; mode: "all-data" | "only-app-db"; requestId: string; } | { _tag: "LSD.Leader.SetSyncLatch.Request"; clientId: string; closeLatch: boolean; liveStoreVersion: "0.3.2-dev.11"; requestId: string; }; } | { _tag: "InitialMessage"; liveStoreVersion: "0.3.2-dev.11"; payload: { _tag: "FromClientSession"; initialMessage: { _tag: "InitialMessage"; clientId: string; debugInstanceId: string; devtoolsEnabled: boolean; storageOptions: { directory?: string; type: "opfs"; }; storeId: string; syncPayload: undefined | JsonValue; }; } | { _tag: "FromWebBridge"; }; } | { _tag: "UpdateMessagePort"; port: MessagePort; }>

readonly _R: Covariant<never>

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).[TypeId]


readonly static [TypeId]: object

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:160

readonly _A: Invariant<CreateConnection | LeaderWorkerInnerBootStatusStream | LeaderWorkerInnerPushToLeader | LeaderWorkerInnerPullStream | LeaderWorkerInnerExport | LeaderWorkerInnerExportEventlog | LeaderWorkerInnerGetRecreateSnapshot | LeaderWorkerInnerGetLeaderHead | LeaderWorkerInnerGetLeaderSyncState | LeaderWorkerInnerShutdown | LeaderWorkerInnerExtraDevtoolsMessage | SharedWorkerInitialMessage | SharedWorkerUpdateMessagePort>

readonly _I: Invariant<{ _tag: "DevtoolsWebCommon.CreateConnection"; from: string; port: MessagePort; } | { _tag: "BootStatusStream"; } | { _tag: "PushToLeader"; batch: readonly object[]; } | { _tag: "PullStream"; cursor: { client: number; global: number; rebaseGeneration: number; }; } | { _tag: "Export"; } | { _tag: "ExportEventlog"; } | { _tag: "GetRecreateSnapshot"; } | { _tag: "GetLeaderHead"; } | { _tag: "GetLeaderSyncState"; } | { _tag: "Shutdown"; } | { _tag: "ExtraDevtoolsMessage"; message: { _tag: "LSD.Leader.SnapshotReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.EventlogReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.NetworkStatusSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.NetworkStatusUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.Disconnect"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.CommitEventReq"; clientId: string; eventEncoded: { args: any; name: string; }; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.Ping"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.DatabaseFileInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHistorySubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHistoryUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncingInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHeadSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHeadUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.LoadDatabaseFile.Request"; clientId: string; data: Uint8Array<ArrayBufferLike>; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.ResetAllData.Request"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; mode: "all-data" | "only-app-db"; requestId: string; } | { _tag: "LSD.Leader.SetSyncLatch.Request"; clientId: string; closeLatch: boolean; liveStoreVersion: "0.3.2-dev.11"; requestId: string; }; } | { _tag: "InitialMessage"; liveStoreVersion: "0.3.2-dev.11"; payload: { _tag: "FromClientSession"; initialMessage: { _tag: "InitialMessage"; clientId: string; debugInstanceId: string; devtoolsEnabled: boolean; storageOptions: { directory?: string; type: "opfs"; }; storeId: string; syncPayload: undefined | JsonValue; }; } | { _tag: "FromWebBridge"; }; } | { _tag: "UpdateMessagePort"; port: MessagePort; }>

readonly _R: Covariant<never>

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).[TypeId]


readonly static ast: AST

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:64

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).ast


readonly static Context: never

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:63

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).Context


readonly static Encoded: { _tag: "DevtoolsWebCommon.CreateConnection"; from: string; port: MessagePort; } | { _tag: "BootStatusStream"; } | { _tag: "PushToLeader"; batch: readonly object[]; } | { _tag: "PullStream"; cursor: { client: number; global: number; rebaseGeneration: number; }; } | { _tag: "Export"; } | { _tag: "ExportEventlog"; } | { _tag: "GetRecreateSnapshot"; } | { _tag: "GetLeaderHead"; } | { _tag: "GetLeaderSyncState"; } | { _tag: "Shutdown"; } | { _tag: "ExtraDevtoolsMessage"; message: { _tag: "LSD.Leader.SnapshotReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.EventlogReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.NetworkStatusSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.NetworkStatusUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.Disconnect"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.CommitEventReq"; clientId: string; eventEncoded: { args: any; name: string; }; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.Ping"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.DatabaseFileInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHistorySubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHistoryUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncingInfoReq"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.SyncHeadSubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.SyncHeadUnsubscribe"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; requestId: string; subscriptionId: string; } | { _tag: "LSD.Leader.LoadDatabaseFile.Request"; clientId: string; data: Uint8Array<ArrayBufferLike>; liveStoreVersion: "0.3.2-dev.11"; requestId: string; } | { _tag: "LSD.Leader.ResetAllData.Request"; clientId: string; liveStoreVersion: "0.3.2-dev.11"; mode: "all-data" | "only-app-db"; requestId: string; } | { _tag: "LSD.Leader.SetSyncLatch.Request"; clientId: string; closeLatch: boolean; liveStoreVersion: "0.3.2-dev.11"; requestId: string; }; } | { _tag: "InitialMessage"; liveStoreVersion: "0.3.2-dev.11"; payload: { _tag: "FromClientSession"; initialMessage: { _tag: "InitialMessage"; clientId: string; debugInstanceId: string; devtoolsEnabled: boolean; storageOptions: { directory?: string; type: "opfs"; }; storeId: string; syncPayload: undefined | JsonValue; }; } | { _tag: "FromWebBridge"; }; } | { _tag: "UpdateMessagePort"; port: MessagePort; }

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:62

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).Encoded


readonly static members: readonly [typeof SharedWorkerInitialMessage, typeof SharedWorkerUpdateMessagePort, typeof LeaderWorkerInnerBootStatusStream, typeof LeaderWorkerInnerPushToLeader, typeof LeaderWorkerInnerPullStream, typeof LeaderWorkerInnerExport, typeof LeaderWorkerInnerGetRecreateSnapshot, typeof LeaderWorkerInnerExportEventlog, typeof LeaderWorkerInnerGetLeaderHead, typeof LeaderWorkerInnerGetLeaderSyncState, typeof LeaderWorkerInnerShutdown, typeof LeaderWorkerInnerExtraDevtoolsMessage, typeof CreateConnection]

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:646

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).members


readonly static Type: CreateConnection | LeaderWorkerInnerBootStatusStream | LeaderWorkerInnerPushToLeader | LeaderWorkerInnerPullStream | LeaderWorkerInnerExport | LeaderWorkerInnerExportEventlog | LeaderWorkerInnerGetRecreateSnapshot | LeaderWorkerInnerGetLeaderHead | LeaderWorkerInnerGetLeaderSyncState | LeaderWorkerInnerShutdown | LeaderWorkerInnerExtraDevtoolsMessage | SharedWorkerInitialMessage | SharedWorkerUpdateMessagePort

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:61

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).Type

static annotations(annotations): Union

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Schema.d.ts:76

Merges a set of new annotations with existing ones, potentially overwriting any duplicates.

GenericSchema<CreateConnection | LeaderWorkerInnerBootStatusStream | LeaderWorkerInnerPushToLeader | LeaderWorkerInnerPullStream | LeaderWorkerInnerExport | LeaderWorkerInnerExportEventlog | LeaderWorkerInnerGetRecreateSnapshot | LeaderWorkerInnerGetLeaderHead | LeaderWorkerInnerGetLeaderSyncState | LeaderWorkerInnerShutdown | LeaderWorkerInnerExtraDevtoolsMessage | SharedWorkerInitialMessage | SharedWorkerUpdateMessagePort>

Union

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).annotations


static pipe<A>(this): A

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:10

A

A

A

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B>(this, ab): B

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:11

A

B = never

A

(_) => B

B

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C>(this, ab, bc): C

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:12

A

B = never

C = never

A

(_) => B

(_) => C

C

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D>(this, ab, bc, cd): D

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:13

A

B = never

C = never

D = never

A

(_) => B

(_) => C

(_) => D

D

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E>(this, ab, bc, cd, de): E

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:14

A

B = never

C = never

D = never

E = never

A

(_) => B

(_) => C

(_) => D

(_) => E

E

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F>(this, ab, bc, cd, de, ef): F

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:15

A

B = never

C = never

D = never

E = never

F = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

F

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G>(this, ab, bc, cd, de, ef, fg): G

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:16

A

B = never

C = never

D = never

E = never

F = never

G = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

G

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H>(this, ab, bc, cd, de, ef, fg, gh): H

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:17

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

H

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I>(this, ab, bc, cd, de, ef, fg, gh, hi): I

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:18

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

I

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J>(this, ab, bc, cd, de, ef, fg, gh, hi, ij): J

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:19

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

J

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk): K

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:20

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

K

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl): L

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:21

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

L

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm): M

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:22

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

M

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn): N

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:23

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

N

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no): O

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:24

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

O

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op): P

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:25

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

P

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op, pq): Q

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:26

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

Q = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

(_) => Q

Q

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op, pq, qr): R

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:27

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

Q = never

R = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

(_) => Q

(_) => R

R

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op, pq, qr, rs): S

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:28

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

Q = never

R = never

S = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

(_) => Q

(_) => R

(_) => S

S

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op, pq, qr, rs, st): T

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:29

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

Q = never

R = never

S = never

T = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

(_) => Q

(_) => R

(_) => S

(_) => T

T

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op, pq, qr, rs, st, tu): U

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:30

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

Q = never

R = never

S = never

T = never

U = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

(_) => Q

(_) => R

(_) => S

(_) => T

(_) => U

U

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe

static pipe<A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T, U>(this, ab, bc, cd, de, ef, fg, gh, hi, ij, jk, kl, lm, mn, no, op, pq, qr, rs, st, tu): U

Defined in: node_modules/.pnpm/effect@3.17.2/node_modules/effect/dist/dts/Pipeable.d.ts:31

A

B = never

C = never

D = never

E = never

F = never

G = never

H = never

I = never

J = never

K = never

L = never

M = never

N = never

O = never

P = never

Q = never

R = never

S = never

T = never

U = never

A

(_) => B

(_) => C

(_) => D

(_) => E

(_) => F

(_) => G

(_) => H

(_) => I

(_) => J

(_) => K

(_) => L

(_) => M

(_) => N

(_) => O

(_) => P

(_) => Q

(_) => R

(_) => S

(_) => T

(_) => U

U

Schema.Union( SharedWorkerInitialMessage, SharedWorkerUpdateMessagePort, // Proxied requests LeaderWorkerInnerBootStatusStream, LeaderWorkerInnerPushToLeader, LeaderWorkerInnerPullStream, LeaderWorkerInnerExport, LeaderWorkerInnerGetRecreateSnapshot, LeaderWorkerInnerExportEventlog, LeaderWorkerInnerGetLeaderHead, LeaderWorkerInnerGetLeaderSyncState, LeaderWorkerInnerShutdown, LeaderWorkerInnerExtraDevtoolsMessage, WebmeshWorker.Schema.CreateConnection, ).pipe