fix: invoke reconnect when readInternal return error

EventStore · Oct 22, 2024 · a77b25e · a77b25e
1 parent 8206ac8
commit a77b25e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/esdb/client.go b/esdb/client.go
@@ -759,7 +759,9 @@ func readInternal(
 	result, err := streamsClient.Read(ctx, readRequest, callOptions...)
 	if err != nil {
 		defer cancel()
-		return nil, err
+
+		err = client.grpcClient.handleError(handle, headers, trailers, err)
+		return nil, fmt.Errorf("could not construct read operation. Reason: %w", err)
 	}
 
 	params := readStreamParams{