(ctx context.Context, w http.ResponseWriter, resp proto.Message, opts []func(context.Context, http.ResponseWriter, proto.Message) error)
| 215 | } |
| 216 | |
| 217 | func handleForwardResponseOptions(ctx context.Context, w http.ResponseWriter, resp proto.Message, opts []func(context.Context, http.ResponseWriter, proto.Message) error) error { |
| 218 | if len(opts) == 0 { |
| 219 | return nil |
| 220 | } |
| 221 | for _, opt := range opts { |
| 222 | if err := opt(ctx, w, resp); err != nil { |
| 223 | return fmt.Errorf("error handling ForwardResponseOptions: %w", err) |
| 224 | } |
| 225 | } |
| 226 | return nil |
| 227 | } |
| 228 | |
| 229 | func handleForwardResponseStreamError(ctx context.Context, wroteHeader bool, marshaler Marshaler, w http.ResponseWriter, req *http.Request, mux *ServeMux, err error, delimiter []byte) { |
| 230 | st := mux.streamErrorHandler(ctx, err) |
no outgoing calls
no test coverage detected