From 12cf076118570eebbff08c6b3090e0d4798447a1 Mon Sep 17 00:00:00 2001
From: cyfraeviolae <cyfraeviolae>
Date: Wed, 3 Apr 2024 03:17:55 -0400
Subject: no venv

---
 .../site-packages/anyio/streams/stapled.py         | 141 ---------------------
 1 file changed, 141 deletions(-)
 delete mode 100644 venv/lib/python3.11/site-packages/anyio/streams/stapled.py

(limited to 'venv/lib/python3.11/site-packages/anyio/streams/stapled.py')

diff --git a/venv/lib/python3.11/site-packages/anyio/streams/stapled.py b/venv/lib/python3.11/site-packages/anyio/streams/stapled.py
deleted file mode 100644
index 80f64a2..0000000
--- a/venv/lib/python3.11/site-packages/anyio/streams/stapled.py
+++ /dev/null
@@ -1,141 +0,0 @@
-from __future__ import annotations
-
-from collections.abc import Callable, Mapping, Sequence
-from dataclasses import dataclass
-from typing import Any, Generic, TypeVar
-
-from ..abc import (
-    ByteReceiveStream,
-    ByteSendStream,
-    ByteStream,
-    Listener,
-    ObjectReceiveStream,
-    ObjectSendStream,
-    ObjectStream,
-    TaskGroup,
-)
-
-T_Item = TypeVar("T_Item")
-T_Stream = TypeVar("T_Stream")
-
-
-@dataclass(eq=False)
-class StapledByteStream(ByteStream):
-    """
-    Combines two byte streams into a single, bidirectional byte stream.
-
-    Extra attributes will be provided from both streams, with the receive stream
-    providing the values in case of a conflict.
-
-    :param ByteSendStream send_stream: the sending byte stream
-    :param ByteReceiveStream receive_stream: the receiving byte stream
-    """
-
-    send_stream: ByteSendStream
-    receive_stream: ByteReceiveStream
-
-    async def receive(self, max_bytes: int = 65536) -> bytes:
-        return await self.receive_stream.receive(max_bytes)
-
-    async def send(self, item: bytes) -> None:
-        await self.send_stream.send(item)
-
-    async def send_eof(self) -> None:
-        await self.send_stream.aclose()
-
-    async def aclose(self) -> None:
-        await self.send_stream.aclose()
-        await self.receive_stream.aclose()
-
-    @property
-    def extra_attributes(self) -> Mapping[Any, Callable[[], Any]]:
-        return {
-            **self.send_stream.extra_attributes,
-            **self.receive_stream.extra_attributes,
-        }
-
-
-@dataclass(eq=False)
-class StapledObjectStream(Generic[T_Item], ObjectStream[T_Item]):
-    """
-    Combines two object streams into a single, bidirectional object stream.
-
-    Extra attributes will be provided from both streams, with the receive stream
-    providing the values in case of a conflict.
-
-    :param ObjectSendStream send_stream: the sending object stream
-    :param ObjectReceiveStream receive_stream: the receiving object stream
-    """
-
-    send_stream: ObjectSendStream[T_Item]
-    receive_stream: ObjectReceiveStream[T_Item]
-
-    async def receive(self) -> T_Item:
-        return await self.receive_stream.receive()
-
-    async def send(self, item: T_Item) -> None:
-        await self.send_stream.send(item)
-
-    async def send_eof(self) -> None:
-        await self.send_stream.aclose()
-
-    async def aclose(self) -> None:
-        await self.send_stream.aclose()
-        await self.receive_stream.aclose()
-
-    @property
-    def extra_attributes(self) -> Mapping[Any, Callable[[], Any]]:
-        return {
-            **self.send_stream.extra_attributes,
-            **self.receive_stream.extra_attributes,
-        }
-
-
-@dataclass(eq=False)
-class MultiListener(Generic[T_Stream], Listener[T_Stream]):
-    """
-    Combines multiple listeners into one, serving connections from all of them at once.
-
-    Any MultiListeners in the given collection of listeners will have their listeners
-    moved into this one.
-
-    Extra attributes are provided from each listener, with each successive listener
-    overriding any conflicting attributes from the previous one.
-
-    :param listeners: listeners to serve
-    :type listeners: Sequence[Listener[T_Stream]]
-    """
-
-    listeners: Sequence[Listener[T_Stream]]
-
-    def __post_init__(self) -> None:
-        listeners: list[Listener[T_Stream]] = []
-        for listener in self.listeners:
-            if isinstance(listener, MultiListener):
-                listeners.extend(listener.listeners)
-                del listener.listeners[:]  # type: ignore[attr-defined]
-            else:
-                listeners.append(listener)
-
-        self.listeners = listeners
-
-    async def serve(
-        self, handler: Callable[[T_Stream], Any], task_group: TaskGroup | None = None
-    ) -> None:
-        from .. import create_task_group
-
-        async with create_task_group() as tg:
-            for listener in self.listeners:
-                tg.start_soon(listener.serve, handler, task_group)
-
-    async def aclose(self) -> None:
-        for listener in self.listeners:
-            await listener.aclose()
-
-    @property
-    def extra_attributes(self) -> Mapping[Any, Callable[[], Any]]:
-        attributes: dict = {}
-        for listener in self.listeners:
-            attributes.update(listener.extra_attributes)
-
-        return attributes
-- 
cgit v1.2.3