usenetbinary-newsreaderfanartsickbeardtvseriesplexswizzinembyseedboxtvdbnzbgetsubtitlewebuiquickboxtraktkodistabletvshowsqnaptautulli
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
57 lines
2.7 KiB
57 lines
2.7 KiB
from tornado_py3 import gen as gen, httputil as httputil
|
|
from tornado_py3.http1connection import HTTP1Connection as HTTP1Connection, HTTP1ConnectionParameters as HTTP1ConnectionParameters
|
|
from tornado_py3.httpclient import AsyncHTTPClient as AsyncHTTPClient, HTTPError as HTTPError, HTTPRequest as HTTPRequest, HTTPResponse as HTTPResponse, main as main
|
|
from tornado_py3.ioloop import IOLoop as IOLoop
|
|
from tornado_py3.iostream import IOStream as IOStream, StreamClosedError as StreamClosedError
|
|
from tornado_py3.log import gen_log as gen_log
|
|
from tornado_py3.netutil import OverrideResolver as OverrideResolver, Resolver as Resolver, is_valid_ip as is_valid_ip
|
|
from tornado_py3.tcpclient import TCPClient as TCPClient
|
|
from typing import Any, Callable, Dict, Optional, Union
|
|
|
|
class HTTPTimeoutError(HTTPError):
|
|
def __init__(self, message: str) -> None: ...
|
|
|
|
class HTTPStreamClosedError(HTTPError):
|
|
def __init__(self, message: str) -> None: ...
|
|
|
|
class SimpleAsyncHTTPClient(AsyncHTTPClient):
|
|
max_clients: Any = ...
|
|
queue: Any = ...
|
|
active: Any = ...
|
|
waiting: Any = ...
|
|
max_buffer_size: Any = ...
|
|
max_header_size: Any = ...
|
|
max_body_size: Any = ...
|
|
resolver: Any = ...
|
|
own_resolver: bool = ...
|
|
tcp_client: Any = ...
|
|
def initialize(self, max_clients: int=..., hostname_mapping: Dict[str, str]=..., max_buffer_size: int=..., resolver: Resolver=..., defaults: Dict[str, Any]=..., max_header_size: int=..., max_body_size: int=...) -> None: ...
|
|
def close(self) -> None: ...
|
|
def fetch_impl(self, request: HTTPRequest, callback: Callable[[HTTPResponse], None]) -> None: ...
|
|
|
|
class _HTTPConnection(httputil.HTTPMessageDelegate):
|
|
io_loop: Any = ...
|
|
start_time: Any = ...
|
|
start_wall_time: Any = ...
|
|
client: Any = ...
|
|
request: Any = ...
|
|
release_callback: Any = ...
|
|
final_callback: Any = ...
|
|
max_buffer_size: Any = ...
|
|
tcp_client: Any = ...
|
|
max_header_size: Any = ...
|
|
max_body_size: Any = ...
|
|
code: Any = ...
|
|
headers: Any = ...
|
|
chunks: Any = ...
|
|
def __init__(self, client: Optional[SimpleAsyncHTTPClient], request: HTTPRequest, release_callback: Callable[[], None], final_callback: Callable[[HTTPResponse], None], max_buffer_size: int, tcp_client: TCPClient, max_header_size: int, max_body_size: int) -> None: ...
|
|
parsed: Any = ...
|
|
parsed_hostname: Any = ...
|
|
stream: Any = ...
|
|
connection: Any = ...
|
|
async def run(self) -> None: ...
|
|
def on_connection_close(self) -> None: ...
|
|
reason: Any = ...
|
|
async def headers_received(self, first_line: Union[httputil.ResponseStartLine, httputil.RequestStartLine], headers: httputil.HTTPHeaders) -> None: ...
|
|
def finish(self) -> None: ...
|
|
def data_received(self, chunk: bytes) -> None: ...
|
|
|