Function sendBody

packages/platform-node/src/internal/httpClient.ts:80–130

(
  nodeRequest: Http.ClientRequest,
  request: ClientRequest.HttpClientRequest,
  body: Body.HttpBody
)

  })

const sendBody = (
  nodeRequest: Http.ClientRequest,
  request: ClientRequest.HttpClientRequest,
  body: Body.HttpBody
): Effect.Effect<void, Error.RequestError> =>
  Effect.suspend((): Effect.Effect<void, Error.RequestError> => {
    switch (body._tag) {
      case "Empty": {
        nodeRequest.end()
        return waitForFinish(nodeRequest, request)
      }
      case "Uint8Array":
      case "Raw": {
        nodeRequest.end(body.body)
        return waitForFinish(nodeRequest, request)
      }
      case "FormData": {
        const response = new Response(body.formData)

        response.headers.forEach((value, key) => {
          nodeRequest.setHeader(key, value)
        })

        return Effect.tryPromise({
          try: () => pipeline(Readable.fromWeb(response.body! as any), nodeRequest),
          catch: (cause) =>
            new Error.RequestError({
              request,
              reason: "Transport",
              cause
            })
        })
      }
      case "Stream": {
        return Stream.run(
          Stream.mapError(body.stream, (cause) =>
            new Error.RequestError({
              request,
              reason: "Encode",
              cause
            })),
          NodeSink.fromWritable(() => nodeRequest, (cause) =>
            new Error.RequestError({
              request,
              reason: "Transport",
              cause
            }))
        )
      }
    }
  })

const waitForResponse = (nodeRequest: Http.ClientRequest, request: ClientRequest.HttpClientRequest) =>
  Effect.async<Http.IncomingMessage, Error.RequestError>((resume) => {