(err error, client safeWriteClient, msgType string)
| 8 | ) |
| 9 | |
| 10 | func handleSendError(err error, client safeWriteClient, msgType string) error { |
| 11 | if err == io.EOF { |
| 12 | // we need to get back the original error |
| 13 | if _, err := client.CloseAndRecv(); err != nil { |
| 14 | if e, ok := status.FromError(err); ok { |
| 15 | return fmt.Errorf("write client returned error (%v): %v", msgType, e.Message()) |
| 16 | } |
| 17 | return fmt.Errorf("failed to close and receive write client (%v): %v", msgType, err) |
| 18 | } |
| 19 | } |
| 20 | return fmt.Errorf("failed to send write request (%v): %w", msgType, err) |
| 21 | } |
no test coverage detected