fix: Heartbeat handling was missing when observing events. (#125)

goloroden · web-flow · commit abd8f5e1bc8f · 2025-05-15T13:58:47.000+02:00
diff --git a/eventsourcingdb/observe_events.go b/eventsourcingdb/observe_events.go
@@ -111,6 +111,8 @@ func (c *Client) ObserveEvents(
 			}
 
 			switch line.Type {
+			case "heartbeat":
+				continue
 			case "event":
 				var event Event
 				err := json.Unmarshal(line.Payload, &event)

Original file line number	Diff line number	Diff line change
`@@ -111,6 +111,8 @@ func (c *Client) ObserveEvents(`
`111`	`111`	`}`
`112`	`112`
`113`	`113`	`switch line.Type {`
	`114`	`+ case "heartbeat":`
	`115`	`+ continue`
`114`	`116`	`case "event":`
`115`	`117`	`var event Event`
`116`	`118`	`err := json.Unmarshal(line.Payload, &event)`