fix: Fix non-returning yields. (#126)

Author: goloroden

eventsourcingdb/observe_events.go

@@ -121,7 +121,9 @@ func (c *Client) ObserveEvents(
 					return
 				}
 
-				yield(event, nil)
+				if !yield(event, nil) {
+					return
+				}
 				continue
 			case "error":
 				var error internal.Error

eventsourcingdb/read_event_types.go

@@ -84,7 +84,9 @@ func (c *Client) ReadEventTypes(
 					Schema:    streamEventType.Schema,
 				}
 
-				yield(eventType, nil)
+				if !yield(eventType, nil) {
+					return
+				}
 				continue
 			case "error":
 				var error internal.Error

eventsourcingdb/read_events.go

@@ -131,7 +131,9 @@ func (c *Client) ReadEvents(
 					return
 				}
 
-				yield(event, nil)
+				if !yield(event, nil) {
+					return
+				}
 				continue
 			case "error":
 				var error internal.Error

eventsourcingdb/read_subjects.go

@@ -84,7 +84,9 @@ func (c *Client) ReadSubjects(
 					return
 				}
 
-				yield(streamSubject.Subject, nil)
+				if !yield(streamSubject.Subject, nil) {
+					return
+				}
 				continue
 			case "error":
 				var error internal.Error

eventsourcingdb/run_event_ql_query.go

@@ -71,7 +71,9 @@ func (c *Client) RunEventQLQuery(
 			case "heartbeat":
 				continue
 			case "row":
-				yield(line.Payload, nil)
+				if !yield(line.Payload, nil) {
+					return
+				}
 				continue
 			case "error":
 				var error internal.Error