mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-04-26 21:05:30 +00:00
fix location of payload defer
This commit is contained in:
@@ -13,11 +13,11 @@ type HTTPResponseEncode struct {
|
|||||||
|
|
||||||
func (hre *HTTPResponseEncode) Process(ctx context.Context, payload any) (any, error) {
|
func (hre *HTTPResponseEncode) Process(ctx context.Context, payload any) (any, error) {
|
||||||
payloadResponse, ok := payload.(*http.Response)
|
payloadResponse, ok := payload.(*http.Response)
|
||||||
defer payloadResponse.Body.Close()
|
|
||||||
|
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, fmt.Errorf("http.response.encode processor only accepts an http.Response")
|
return nil, fmt.Errorf("http.response.encode processor only accepts an http.Response")
|
||||||
}
|
}
|
||||||
|
defer payloadResponse.Body.Close()
|
||||||
|
|
||||||
bytes, err := io.ReadAll(payloadResponse.Body)
|
bytes, err := io.ReadAll(payloadResponse.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user