return 'Digest %s' % (base)
- def handle_401(self, r):
+ def handle_401(self, r, **kwargs):
"""Takes the given response and tries digest-auth, if needed."""
num_401_calls = getattr(self, 'num_401_calls', 1)
r.raw.release_conn()
r.request.headers['Authorization'] = self.build_digest_header(r.request.method, r.request.url)
- _r = r.connection.send(r.request)
+ _r = r.connection.send(r.request, **kwargs)
_r.history.append(r)
return _r
# TODO: response is the only one
-def dispatch_hook(key, hooks, hook_data):
+def dispatch_hook(key, hooks, hook_data, **kwargs):
"""Dispatches a hook dictionary on a given piece of data."""
hooks = hooks or dict()
hooks = [hooks]
for hook in hooks:
- _hook_data = hook(hook_data)
+ _hook_data = hook(hook_data, **kwargs)
if _hook_data is not None:
hook_data = _hook_data
r.elapsed = datetime.utcnow() - start
# Response manipulation hooks
- r = dispatch_hook('response', hooks, r)
+ r = dispatch_hook('response', hooks, r, **kwargs)
# Redirect resolving generator.
gen = self.resolve_redirects(r, request, stream=stream,