Function send

packages/rpc/src/RpcClient.ts:850–907

(request: FromClientEncoded)

    const isJson = serialization.contentType === "application/json"

    const send = (request: FromClientEncoded): Effect.Effect<void, RpcClientError> => {
      if (request._tag !== "Request") {
        return Effect.void
      }

      const parser = serialization.unsafeMake()

      const encoded = parser.encode(request)!
      const body = typeof encoded === "string" ?
        HttpBody.text(encoded, serialization.contentType) :
        HttpBody.uint8Array(encoded, serialization.contentType)

      if (isJson) {
        return client.post("", { body }).pipe(
          Effect.flatMap((r) => r.json),
          Effect.mapError((cause) =>
            new RpcClientError({
              reason: "Protocol",
              message: "Failed to send HTTP request",
              cause
            })
          ),
          Effect.flatMap((u) => {
            if (!Array.isArray(u)) {
              return Effect.dieMessage(`Expected an array of responses, but got: ${u}`)
            }
            let i = 0
            return Effect.whileLoop({
              while: () => i < u.length,
              body: () => writeResponse(u[i++]),
              step: constVoid
            })
          })
        )
      }

      return client.post("", { body }).pipe(
        Effect.flatMap((r) =>
          Stream.runForEachChunk(r.stream, (chunk) => {
            const responses = Chunk.toReadonlyArray(chunk).flatMap(parser.decode) as Array<FromServerEncoded>
            if (responses.length === 0) return Effect.void
            let i = 0
            return Effect.whileLoop({
              while: () => i < responses.length,
              body: () => writeResponse(responses[i++]),
              step: constVoid
            })
          })
        ),
        Effect.mapError((cause) =>
          new RpcClientError({
            reason: "Protocol",
            message: "Failed to send HTTP request",
            cause
          })
        )
      )
    }