| 2692 | """Ensure that server-sent headers/trailers make it through.""" |
| 2693 | |
| 2694 | class HeadersTrailersFlightServer(FlightServerBase): |
| 2695 | def get_flight_info(self, context, descriptor): |
| 2696 | context.add_header("x-header", "header-value") |
| 2697 | context.add_header("x-header-bin", "header\x01value") |
| 2698 | context.add_trailer("x-trailer", "trailer-value") |
| 2699 | context.add_trailer("x-trailer-bin", "trailer\x01value") |
| 2700 | return flight.FlightInfo( |
| 2701 | pa.schema([]), |
| 2702 | descriptor, |
| 2703 | [] |
| 2704 | ) |
| 2705 | |
| 2706 | class HeadersTrailersMiddlewareFactory(ClientMiddlewareFactory): |
| 2707 | def __init__(self): |
no outgoing calls