diff --git a/wsjson/wsjson.go b/wsjson/wsjson.go
index 99996a69a0ba23bda23fc8ed6f79d4c6da123224..2000a77af8dc5f0296142cbdeefd5af780f442b8 100644
--- a/wsjson/wsjson.go
+++ b/wsjson/wsjson.go
@@ -20,16 +20,11 @@ func Read(ctx context.Context, c *websocket.Conn, v interface{}) error {
 func read(ctx context.Context, c *websocket.Conn, v interface{}) (err error) {
 	defer errd.Wrap(&err, "failed to read JSON message")
 
-	typ, r, err := c.Reader(ctx)
+	_, r, err := c.Reader(ctx)
 	if err != nil {
 		return err
 	}
 
-	if typ != websocket.MessageText {
-		c.Close(websocket.StatusUnsupportedData, "expected text message")
-		return fmt.Errorf("expected text message for JSON but got: %v", typ)
-	}
-
 	b := bpool.Get()
 	defer bpool.Put(b)