File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed
engine/access/rest/websockets Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change @@ -3,7 +3,6 @@ package websockets
33import (
44 "context"
55 "encoding/json"
6- "errors"
76 "fmt"
87 "sync"
98
@@ -16,8 +15,6 @@ import (
1615 "github.com/onflow/flow-go/utils/concurrentmap"
1716)
1817
19- var ErrEmptyMessage = errors .New ("empty message" )
20-
2118type Controller struct {
2219 logger zerolog.Logger
2320 config Config
@@ -97,8 +94,6 @@ func (c *Controller) readMessages(ctx context.Context) {
9794 if websocket .IsCloseError (err , websocket .CloseNormalClosure , websocket .CloseAbnormalClosure ) ||
9895 websocket .IsUnexpectedCloseError (err , websocket .CloseNormalClosure , websocket .CloseGoingAway ) {
9996 return
100- } else if errors .Is (err , ErrEmptyMessage ) {
101- continue
10297 }
10398
10499 c .logger .Debug ().Err (err ).Msg ("error reading message from client" )
@@ -126,10 +121,6 @@ func (c *Controller) readMessage() (json.RawMessage, error) {
126121 return nil , fmt .Errorf ("error reading JSON from client: %w" , err )
127122 }
128123
129- if message == nil {
130- return nil , ErrEmptyMessage
131- }
132-
133124 return message , nil
134125}
135126
You can’t perform that action at this time.
0 commit comments