ULTRA [ growontech.com ]

Linux premium216.web-hosting.com 4.18.0-513.18.1.lve.el8.x86_64 #1 SMP Thu Feb 22 12:55:50 UTC 2024 x86_64

LiteSpeed

66.29.141.148 | Your IP: 3.135.214.184

Cant read [ /etc/named.conf ]

[ drwxr-xr-x ]

/ opt / cloudlinux / venv / lib64 / python3.11 / site-packages / aiohttp /

Home Upload Mass Deface Mass Delete Back Connect Notify

payload_streamer.py

"""
Payload implementation for coroutines as data provider.

As a simple case, you can upload data from file::

@aiohttp.streamer
   async def file_sender(writer, file_name=None):
      with open(file_name, 'rb') as f:
          chunk = f.read(2**16)
          while chunk:
              await writer.write(chunk)

chunk = f.read(2**16)

Then you can use `file_sender` like this:

async with session.post('http://httpbin.org/post',
                            data=file_sender(file_name='huge_file')) as resp:
        print(await resp.text())

..note:: Coroutine must accept `writer` as first argument

"""

import types
import warnings
from typing import Any, Awaitable, Callable, Dict, Tuple

from .abc import AbstractStreamWriter
from .payload import Payload, payload_type

__all__ = ("streamer",)

class _stream_wrapper:
    def __init__(
        self,
        coro: Callable[..., Awaitable[None]],
        args: Tuple[Any, ...],
        kwargs: Dict[str, Any],
    ) -> None:
        self.coro = types.coroutine(coro)
        self.args = args
        self.kwargs = kwargs

async def __call__(self, writer: AbstractStreamWriter) -> None:
        await self.coro(writer, *self.args, **self.kwargs)

class streamer:
    def __init__(self, coro: Callable[..., Awaitable[None]]) -> None:
        warnings.warn(
            "@streamer is deprecated, use async generators instead",
            DeprecationWarning,
            stacklevel=2,
        )
        self.coro = coro

def __call__(self, *args: Any, **kwargs: Any) -> _stream_wrapper:
        return _stream_wrapper(self.coro, args, kwargs)

@payload_type(_stream_wrapper)
class StreamWrapperPayload(Payload):
    async def write(self, writer: AbstractStreamWriter) -> None:
        await self._value(writer)

@payload_type(streamer)
class StreamPayload(StreamWrapperPayload):
    def __init__(self, value: Any, *args: Any, **kwargs: Any) -> None:
        super().__init__(value(), *args, **kwargs)

async def write(self, writer: AbstractStreamWriter) -> None:
        await self._value(writer)

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	drwxr-xr-x	2025-01-11 06:01:10
..	dir	-	root/root	drwxr-xr-x	2025-02-27 06:01:09
.hash	dir	-	root/root	drwxr-xr-x	2025-01-11 06:01:10
__pycache__	dir	-	root/root	drwxr-xr-x	2025-01-11 06:04:47
__init__.py	text/x-script.python	7.58 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
_cparser.pxd	text/plain	4.22 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
_find_header.pxd	text/plain	68 B	root/root	-rw-r--r--	2024-12-18 10:23:16
_headers.pxi	text/x-script.python	1.96 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
_helpers.cpython-311-x86_64-linux-gnu.so	application/x-pie-executable	86.01 KB	root/root	-rwxr-xr-x	2024-12-18 10:23:52
_helpers.pyi	text/x-script.python	202 B	root/root	-rw-r--r--	2024-12-18 10:23:16
_helpers.pyx	text/x-script.python	1.02 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
_http_parser.cpython-311-x86_64-linux-gnu.so	application/x-pie-executable	569.59 KB	root/root	-rwxr-xr-x	2024-12-18 10:23:52
_http_parser.pyx	text/x-script.python	27.4 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
_http_writer.cpython-311-x86_64-linux-gnu.so	application/x-pie-executable	75.01 KB	root/root	-rwxr-xr-x	2024-12-18 10:23:52
_http_writer.pyx	text/x-script.python	4.47 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
_websocket.cpython-311-x86_64-linux-gnu.so	application/x-pie-executable	53.37 KB	root/root	-rwxr-xr-x	2024-12-18 10:23:52
_websocket.pyx	text/x-script.python	1.52 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
abc.py	text/x-script.python	5.37 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
base_protocol.py	text/x-script.python	2.68 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
client.py	text/plain	46.17 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
client_exceptions.py	text/plain	9.19 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
client_proto.py	text/x-script.python	8.45 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
client_reqrep.py	text/x-script.python	38.75 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
client_ws.py	text/plain	10.75 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
compression_utils.py	text/x-script.python	4.9 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
connector.py	text/x-script.python	51.56 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
cookiejar.py	text/x-script.python	13.69 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
formdata.py	text/x-script.python	5.96 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
hdrs.py	text/plain	4.5 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
helpers.py	text/plain	29.55 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
http.py	text/x-script.python	1.8 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
http_exceptions.py	text/plain	2.65 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
http_parser.py	text/x-script.python	34.66 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
http_websocket.py	text/plain	26.09 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
http_writer.py	text/plain	5.79 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
locks.py	text/x-script.python	1.11 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
log.py	text/plain	325 B	root/root	-rw-r--r--	2024-12-18 10:23:16
multipart.py	text/x-script.python	31.71 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
payload.py	text/x-script.python	13.22 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
payload_streamer.py	text/plain	2.04 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
py.typed	text/plain	7 B	root/root	-rw-r--r--	2024-12-18 10:23:16
pytest_plugin.py	text/x-script.python	11.33 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
resolver.py	text/x-script.python	4.95 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
streams.py	text/x-script.python	20.35 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
tcp_helpers.py	text/plain	961 B	root/root	-rw-r--r--	2024-12-18 10:23:16
test_utils.py	text/plain	19.71 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
tracing.py	text/x-script.python	14.78 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
typedefs.py	text/x-script.python	1.44 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web.py	text/x-script.python	18.81 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_app.py	text/x-script.python	17.88 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_exceptions.py	text/x-script.python	10.12 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_fileresponse.py	text/x-script.python	11.15 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_log.py	text/x-script.python	7.62 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_middlewares.py	text/x-script.python	3.94 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_protocol.py	text/x-script.python	22.5 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_request.py	text/x-script.python	28.08 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_response.py	text/x-script.python	27.08 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_routedef.py	text/x-script.python	5.99 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_runner.py	text/x-script.python	11.46 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_server.py	text/plain	2.53 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_urldispatcher.py	text/x-script.python	39.12 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
web_ws.py	text/x-script.python	18.21 KB	root/root	-rw-r--r--	2024-12-18 10:23:16
worker.py	text/plain	7.78 KB	root/root	-rw-r--r--	2024-12-18 10:23:16