(
self,
future,
callback_type,
before_subscribers=None,
after_subscribers=None,
)
| 728 | ) |
| 729 | |
| 730 | def get_crt_callback( |
| 731 | self, |
| 732 | future, |
| 733 | callback_type, |
| 734 | before_subscribers=None, |
| 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 | |
| 755 | def _get_make_request_args_put_object( |
| 756 | self, |
no outgoing calls
no test coverage detected