diff --git a/driver/websocketdriver/event_receiver.go b/driver/websocketdriver/event_receiver.go
index 381aa40..be0f5fd 100644
--- 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
 	}
 }