diff --git a/sd/consul/instancer.go b/sd/consul/instancer.go
index ce267ec..1110665 100644
--- a/sd/consul/instancer.go
+++ b/sd/consul/instancer.go
@@ -70,7 +70,7 @@
 		index := lastIndex
 		instances, index, err = s.getInstances(lastIndex, s.quitc)
 		switch {
-		case err == errStopped:
+		case errors.Is(err, errStopped):
 			return // stopped via quitc
 		case err != nil:
 			s.logger.Log("err", err)
diff --git a/transport/http/jsonrpc/server_test.go b/transport/http/jsonrpc/server_test.go
index c05435d..210d5b3 100644
--- a/transport/http/jsonrpc/server_test.go
+++ b/transport/http/jsonrpc/server_test.go
@@ -152,7 +152,7 @@
 func TestServerErrorEncoder(t *testing.T) {
 	errTeapot := errors.New("teapot")
 	code := func(err error) int {
-		if err == errTeapot {
+		if errors.Is(err, errTeapot) {
 			return http.StatusTeapot
 		}
 		return http.StatusInternalServerError
diff --git a/transport/http/server_test.go b/transport/http/server_test.go
index c435927..5c0fadb 100644
--- a/transport/http/server_test.go
+++ b/transport/http/server_test.go
@@ -59,7 +59,7 @@
 func TestServerErrorEncoder(t *testing.T) {
 	errTeapot := errors.New("teapot")
 	code := func(err error) int {
-		if err == errTeapot {
+		if errors.Is(err, errTeapot) {
 			return http.StatusTeapot
 		}
 		return http.StatusInternalServerError
diff --git a/transport/nats/subscriber_test.go b/transport/nats/subscriber_test.go
index fc97c1f..d45fe46 100644
--- a/transport/nats/subscriber_test.go
+++ b/transport/nats/subscriber_test.go
@@ -116,7 +116,7 @@
 
 	errTeapot := errors.New("teapot")
 	code := func(err error) error {
-		if err == errTeapot {
+		if errors.Is(err, errTeapot) {
 			return err
 		}
 		return errors.New("dang")