(self, context, descriptor, reader, writer)
| 2391 | return flight.GeneratorStream(schema, itertools.repeat(rb)) |
| 2392 | |
| 2393 | def do_exchange(self, context, descriptor, reader, writer): |
| 2394 | schema = pa.schema([]) |
| 2395 | rb = pa.RecordBatch.from_arrays([], schema=schema) |
| 2396 | writer.begin(schema) |
| 2397 | while not context.is_cancelled(): |
| 2398 | writer.write_batch(rb) |
| 2399 | time.sleep(0.5) |
| 2400 | |
| 2401 | |
| 2402 | @pytest.mark.threading |
nothing calls this directly
no test coverage detected