fix(websocket driver): fix unnecessary error return statement

lukasl-dev · Aug 1, 2021 · fd0f612 · fd0f612
1 parent 898280a
commit fd0f612
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/driver/websocketdriver/event_receiver.go b/driver/websocketdriver/event_receiver.go
@@ -57,10 +57,9 @@ func (e *eventReceiver) Events() <-chan event.Event {
 func (e *eventReceiver) start() {
 	for {
 		evt, err := e.unmarshal()
-		if err != nil {
-			return
+		if err == nil {
+			e.events <- evt
 		}
-		e.events <- evt
 	}
 }