(self, context, action)
| 749 | """A Flight server that tests multiple arbitrary headers.""" |
| 750 | |
| 751 | def do_action(self, context, action): |
| 752 | middleware = context.get_middleware("arbitrary-headers") |
| 753 | if middleware: |
| 754 | headers = middleware.sending_headers() |
| 755 | header_1 = case_insensitive_header_lookup( |
| 756 | headers, |
| 757 | 'test-header-1' |
| 758 | ) |
| 759 | header_2 = case_insensitive_header_lookup( |
| 760 | headers, |
| 761 | 'test-header-2' |
| 762 | ) |
| 763 | value1 = header_1[0].encode("utf-8") |
| 764 | value2 = header_2[0].encode("utf-8") |
| 765 | return [value1, value2] |
| 766 | raise flight.FlightServerError("No headers middleware found") |
| 767 | |
| 768 | |
| 769 | class HeaderServerMiddleware(ServerMiddleware): |
nothing calls this directly
no test coverage detected