Return an error to close the stream if decoding an event fails

Co-authored-by: Philip Potter <[email protected]>

stream.go

@@ -208,6 +208,7 @@ func (r *Client) streamPrediction(ctx context.Context, prediction *Prediction, l
 					event := SSEEvent{Type: SSETypeDefault}
 					if err := event.decode(b); err != nil {
 						errChan <- err
+						return err
 					}
 
 					sseChan <- event