(step_result)
| 479 | user_callback = lambda step_result: False |
| 480 | |
| 481 | def _callback(step_result): |
| 482 | user_callback_result = user_callback(step_result) |
| 483 | step_results.put(step_result) |
| 484 | |
| 485 | return generator_closed.is_set() or user_callback_result |
| 486 | |
| 487 | kwargs.update( |
| 488 | { |