Method
__init__
(self, endpoint, cacert=None, debug=False, basic_auth=None)
Source from the content-addressed store, hash-verified
| 740 | |
| 741 | class StreamManager(ResourceManager): |
| 742 | def __init__(self, endpoint, cacert=None, debug=False, basic_auth=None): |
| 743 | super(StreamManager, self).__init__( |
| 744 | resource=None, |
| 745 | endpoint=endpoint, |
| 746 | cacert=cacert, |
| 747 | debug=debug, |
| 748 | basic_auth=basic_auth, |
| 749 | ) |
| 750 | self._url = httpclient.get_url_without_trailing_slash(endpoint) + "/stream" |
| 751 | |
| 752 | @add_auth_token_to_kwargs_from_env |
| 753 | def listen(self, events=None, **kwargs): |
Callers
nothing calls this directly
Tested by
no test coverage detected