Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions packages/cluster/src/RunnerServer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -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.
*
Expand Down
10 changes: 5 additions & 5 deletions packages/rpc/src/RpcClient.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1045,18 +1045,18 @@ const defaultRetrySchedule = Schedule.exponential(500, 1.5).pipe(
)

const makePinger = Effect.fnUntraced(function*<A, E, R>(writePing: Effect.Effect<A, E, R>) {
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"),
Expand Down
2 changes: 1 addition & 1 deletion packages/rpc/src/RpcSerialization.ts
Original file line number Diff line number Diff line change
Expand Up @@ -423,7 +423,7 @@ export const layerJsonRpc = (options?: {
}): Layer.Layer<RpcSerialization> => 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
Expand Down
2 changes: 1 addition & 1 deletion packages/sql/src/Statement.ts
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,7 @@ export interface Constructor {
readonly or: (clauses: ReadonlyArray<string | Fragment>) => 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
*/
Expand Down