()
| 284 | q = queue.Queue(maxsize=1) |
| 285 | |
| 286 | def _open(): |
| 287 | try: |
| 288 | q.put(("ok", open_stream(url, data, headers))) |
| 289 | except BaseException as e: |
| 290 | q.put(("err", e)) |
| 291 | |
| 292 | threading.Thread(target=_open, daemon=True).start() |
| 293 | keepalive = b": csswitch-keepalive\n\n" |
nothing calls this directly
no test coverage detected