Method writeJsonBody

executor/http_executor.go:225–234

(bodyWriter *io.PipeWriter, parameters []ExecutionParameter, cancel context.CancelCauseFunc)

}

func (e HttpExecutor) writeJsonBody(bodyWriter *io.PipeWriter, parameters []ExecutionParameter, cancel context.CancelCauseFunc) {
	go func() {
		defer func() { _ = bodyWriter.Close() }()
		err := e.serializeJson(bodyWriter, parameters)
		if err != nil {
			cancel(err)
			return
		}
	}()
}

func (e HttpExecutor) writeBody(ctx ExecutionContext, cancel context.CancelCauseFunc) (io.ReadCloser, string, int64, int64) {
	if ctx.Input != nil {