Function writeGen

packages/experimental/src/EventLogRemote.ts:264–273

(request: typeof ProtocolRequest.Type)

    const writeRaw = yield* socket.writer

    function* writeGen(request: typeof ProtocolRequest.Type) {
      const data = encodeRequest(request)
      if (request._tag !== "WriteEntries" || data.byteLength <= constChunkSize) {
        return yield* writeRaw(data)
      }
      const id = request.id
      for (const part of ChunkedMessage.split(id, data)) {
        yield* writeRaw(encodeRequest(part))
      }
    }

    const write = (request: typeof ProtocolRequest.Type) => Effect.gen(() => writeGen(request))