.

Author: m110

pkg/http/marshall_message_test.go

@@ -2,7 +2,6 @@ package http_test
 
 import (
 	"encoding/json"
-	"io/ioutil"
 	"net/http"
 	"testing"
 
@@ -36,7 +35,7 @@ func TestDefaultMarshalMessageFunc(t *testing.T) {
 
 	assert.Equal(t, url, req.URL.String())
 
-	body, err := ioutil.ReadAll(req.Body)
+	body, err := io.ReadAll(req.Body)
 	require.NoError(t, err)
 	assert.Equal(t, msgPayload, body)
 

pkg/http/publisher.go

@@ -3,7 +3,6 @@ package http
 import (
 	"bytes"
 	"encoding/json"
-	"io/ioutil"
 	"net/http"
 
 	"github.com/pkg/errors"
@@ -146,7 +145,7 @@ func (p Publisher) handleResponseBody(resp *http.Response, logFields watermill.L
 		return nil
 	}
 
-	body, err := ioutil.ReadAll(resp.Body)
+	body, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return errors.Wrap(err, "could not read response body")
 	}

pkg/http/sse_test.go

@@ -7,7 +7,6 @@ import (
 	"encoding/json"
 	"errors"
 	"io"
-	"io/ioutil"
 	netHTTP "net/http"
 	"net/http/httptest"
 	"strings"
@@ -75,7 +74,7 @@ func TestSSE(t *testing.T) {
 		require.NoError(t, err)
 
 		require.Equal(t, 200, resp.StatusCode)
-		body, err := ioutil.ReadAll(resp.Body)
+		body, err := io.ReadAll(resp.Body)
 		require.NoError(t, err)
 
 		post := Post{}

pkg/http/subscriber.go

@@ -3,7 +3,6 @@ package http
 import (
 	"context"
 	"encoding/json"
-	"io/ioutil"
 	"net"
 	"net/http"
 	"strings"
@@ -21,7 +20,7 @@ type UnmarshalMessageFunc func(topic string, request *http.Request) (*message.Me
 // DefaultUnmarshalMessageFunc retrieves the UUID and Metadata from request headers,
 // as encoded by DefaultMarshalMessageFunc.
 func DefaultUnmarshalMessageFunc(topic string, req *http.Request) (*message.Message, error) {
-	body, err := ioutil.ReadAll(req.Body)
+	body, err := io.ReadAll(req.Body)
 	if err != nil {
 		return nil, err
 	}