(clientId, message)
| 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, |
no test coverage detected