stream-join-get-results-destructive

Status: IN

`get_results()` swaps out and resets the accumulated results list; callers see only results since the previous drain (pull-based consumption model)

Source: entries/2026/05/29/stream-join-processor-stream_join_processor.md

Example

def get_results(self):
    results = list(self._results)
    self._results.clear()
    return results

JSON