| ... |
... |
@@ -73,8 +73,8 @@ class HTTPSession: |
|
73
|
73
|
|
|
74
|
74
|
self._session.set_proxy_resolver(resolver)
|
|
75
|
75
|
|
|
76
|
|
- def create_request(self) -> HTTPRequest:
|
|
77
|
|
- return HTTPRequest(self)
|
|
|
76
|
+ def create_request(self, force_http1: bool = False) -> HTTPRequest:
|
|
|
77
|
+ return HTTPRequest(self, force_http1=force_http1)
|
|
78
|
78
|
|
|
79
|
79
|
|
|
80
|
80
|
class HTTPRequest(GObject.GObject):
|
| ... |
... |
@@ -90,7 +90,10 @@ class HTTPRequest(GObject.GObject): |
|
90
|
90
|
'destroy': (SIGNAL_ACTIONS, None, ()),
|
|
91
|
91
|
}
|
|
92
|
92
|
|
|
93
|
|
- def __init__(self, session: HTTPSession) -> None:
|
|
|
93
|
+ def __init__(self,
|
|
|
94
|
+ session: HTTPSession,
|
|
|
95
|
+ force_http1: bool = False
|
|
|
96
|
+ ) -> None:
|
|
94
|
97
|
GObject.GObject.__init__(self)
|
|
95
|
98
|
|
|
96
|
99
|
self._log = HTTPLogAdapter(log, extra={'request': self})
|
| ... |
... |
@@ -126,6 +129,7 @@ class HTTPRequest(GObject.GObject): |
|
126
|
129
|
self._emit_response_progress = False
|
|
127
|
130
|
|
|
128
|
131
|
self._message = Soup.Message()
|
|
|
132
|
+ self._message.set_force_http1(force_http1)
|
|
129
|
133
|
self._user_data = None
|
|
130
|
134
|
|
|
131
|
135
|
self._log.info('Created')
|
| ... |
... |
@@ -311,6 +315,8 @@ class HTTPRequest(GObject.GObject): |
|
311
|
315
|
result: Gio.AsyncResult
|
|
312
|
316
|
) -> None:
|
|
313
|
317
|
|
|
|
318
|
+ self._log.info('HTTP version: %s',
|
|
|
319
|
+ self._message.get_http_version().value_name)
|
|
314
|
320
|
self._log.info('Request response received')
|
|
315
|
321
|
try:
|
|
316
|
322
|
self._input_stream = session.send_finish(result)
|