MCPcopy Index your code
hub / github.com/Effect-TS/effect / write

Function write

packages/cluster/src/internal/entityManager.ts:321–326  ·  view source on GitHub ↗
(clientId, message)

Source from the content-addressed store, hash-verified

319 scope,
320 address,
321 write(clientId, message) {
322 if (writeRef.state.current._tag !== "Acquired") {
323 return Effect.flatMap(writeRef.await, (write) => write(clientId, message))
324 }
325 return writeRef.state.current.value(clientId, message)
326 },
327 activeRequests,
328 lastActiveCheck: clock.unsafeCurrentTimeMillis(),
329 keepAliveLatch,

Callers 1

makeClientRespondFunction · 0.50

Calls 1

valueMethod · 0.45

Tested by

no test coverage detected