| 207 | } |
| 208 | |
| 209 | func (e HttpExecutor) writeUrlEncodedBody(bodyWriter *io.PipeWriter, parameters []ExecutionParameter, cancel context.CancelCauseFunc) { |
| 210 | go func() { |
| 211 | defer func() { _ = bodyWriter.Close() }() |
| 212 | queryStringBuilder := converter.NewQueryStringBuilder() |
| 213 | for _, parameter := range parameters { |
| 214 | queryStringBuilder.Add(parameter.Name, parameter.Value) |
| 215 | } |
| 216 | queryString := queryStringBuilder.Build() |
| 217 | _, err := bodyWriter.Write([]byte(queryString)) |
| 218 | if err != nil { |
| 219 | cancel(err) |
| 220 | return |
| 221 | } |
| 222 | }() |
| 223 | } |
| 224 | |
| 225 | func (e HttpExecutor) writeJsonBody(bodyWriter *io.PipeWriter, parameters []ExecutionParameter, cancel context.CancelCauseFunc) { |
| 226 | go func() { |