in http/get_multipart/python/server/server.py [0:0]
def _gen_buffers(self, boundary, json_header, schema, source):
# JSON header
yield from gen_json_multipart_buffers(boundary, json_header)
# Arrow data
is_last_part = not self._include_footnotes
self._start_arrow_stream_time = time.time()
for buffer in gen_arrow_multipart_buffers(
boundary, schema, source, is_last_part=is_last_part
):
self._number_of_arrow_data_chunks += 1
self._bytes_sent_on_arrow_stream += len(buffer)
yield buffer
self._end_arrow_stream_time = time.time()
# Footnotes (optional)
if self._include_footnotes:
footnotes = self._build_footnotes()
yield multipart_buffer_from_string(
boundary, "text/plain", footnotes, is_last_part=True
)