(*args, **kwargs)
| 735 | after_subscribers=None, |
| 736 | ): |
| 737 | def invoke_all_callbacks(*args, **kwargs): |
| 738 | callbacks_list = [] |
| 739 | if before_subscribers is not None: |
| 740 | callbacks_list += before_subscribers |
| 741 | callbacks_list += get_callbacks(future, callback_type) |
| 742 | if after_subscribers is not None: |
| 743 | callbacks_list += after_subscribers |
| 744 | for callback in callbacks_list: |
| 745 | # The get_callbacks helper will set the first augment |
| 746 | # by keyword, the other augments need to be set by keyword |
| 747 | # as well |
| 748 | if callback_type == "progress": |
| 749 | callback(bytes_transferred=args[0]) |
| 750 | else: |
| 751 | callback(*args, **kwargs) |
| 752 | |
| 753 | return invoke_all_callbacks |
| 754 |
nothing calls this directly
no test coverage detected