From 63d3f4256abb5e58d02b59b673103a40b7829542 Mon Sep 17 00:00:00 2001 From: alex mitre Date: Fri, 6 Mar 2026 11:59:55 -0600 Subject: [PATCH] fix: correct typos in source code (receive, separate, committed) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Fix spelling errors in: - packages/cluster/src/RunnerServer.ts: recieves → receives, recieve → receive - packages/rpc/src/RpcClient.ts: recievedPong → receivedPong - packages/rpc/src/RpcSerialization.ts: seperated → separated - packages/sql/src/Statement.ts: seperate → separate --- packages/cluster/src/RunnerServer.ts | 4 ++-- packages/rpc/src/RpcClient.ts | 10 +++++----- packages/rpc/src/RpcSerialization.ts | 2 +- packages/sql/src/Statement.ts | 2 +- 4 files changed, 9 insertions(+), 9 deletions(-) diff --git a/packages/cluster/src/RunnerServer.ts b/packages/cluster/src/RunnerServer.ts index b09e960794f..3d651851b04 100644 --- a/packages/cluster/src/RunnerServer.ts +++ b/packages/cluster/src/RunnerServer.ts @@ -139,7 +139,7 @@ export const layerHandlers = Runners.Rpcs.toLayer(Effect.gen(function*() { const constWaitUntilRead = { waitUntilRead: true } as const /** - * The `RunnerServer` recieves messages from other Runners and forwards them to the + * The `RunnerServer` receives messages from other Runners and forwards them to the * `Sharding` layer. * * It also responds to `Ping` requests. @@ -179,7 +179,7 @@ export const layerWithClients: Layer.Layer< /** * A `Runners` layer that is client only. * - * It will not register with RunnerStorage and recieve shard assignments, + * It will not register with RunnerStorage and receive shard assignments, * so this layer can be used to embed a cluster client inside another effect * application. * diff --git a/packages/rpc/src/RpcClient.ts b/packages/rpc/src/RpcClient.ts index fb6ecbc72ec..da7635cb6ee 100644 --- a/packages/rpc/src/RpcClient.ts +++ b/packages/rpc/src/RpcClient.ts @@ -1045,18 +1045,18 @@ const defaultRetrySchedule = Schedule.exponential(500, 1.5).pipe( ) const makePinger = Effect.fnUntraced(function*(writePing: Effect.Effect) { - let recievedPong = true + let receivedPong = true const latch = Effect.unsafeMakeLatch() const reset = () => { - recievedPong = true + receivedPong = true latch.unsafeClose() } const onPong = () => { - recievedPong = true + receivedPong = true } yield* Effect.suspend(() => { - if (!recievedPong) return latch.open - recievedPong = false + if (!receivedPong) return latch.open + receivedPong = false return writePing }).pipe( Effect.delay("10 seconds"), diff --git a/packages/rpc/src/RpcSerialization.ts b/packages/rpc/src/RpcSerialization.ts index 4286c3e1c4b..d521a7d65c4 100644 --- a/packages/rpc/src/RpcSerialization.ts +++ b/packages/rpc/src/RpcSerialization.ts @@ -423,7 +423,7 @@ export const layerJsonRpc = (options?: { }): Layer.Layer => Layer.succeed(RpcSerialization, jsonRpc(options)) /** - * A rpc serialization layer that uses JSON-RPC for serialization seperated by + * A rpc serialization layer that uses JSON-RPC for serialization separated by * new lines. * * @since 1.0.0 diff --git a/packages/sql/src/Statement.ts b/packages/sql/src/Statement.ts index 1858cdb7ccc..cd54bafd3e1 100644 --- a/packages/sql/src/Statement.ts +++ b/packages/sql/src/Statement.ts @@ -322,7 +322,7 @@ export interface Constructor { readonly or: (clauses: ReadonlyArray) => Fragment /** - * Create comma seperated values, with an optional prefix + * Create comma separated values, with an optional prefix * * Useful for `ORDER BY` and `GROUP BY` clauses */