Upgrading anyio 1 to 2
Unknown1.4.0 → 2.2.0
UnknownUpgrade verdict
DepDelta hasn't looked for this range's notes yet, so breaking changes can't be ruled out.
In plain terms
- DepDelta hasn't finished looking for the notes in this range, so it can't rule out breaking changes yet.
- Their commits are listed with this comparison.
Must act Unknown for releases without notes
Releases without notes may still need changes. Check their commits before upgrading.
Python requirement changed in 2.0.0b1: >=3.5.3 → >=3.6.2.
Drops async-generator.
Installs 2 packages in all (was 3).
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- removed:
async function connect_tcp(address: IPAddressType, port: int, *, ssl_context: Optional[SSLContext]=…, autostart_tls: bool=…, bind_host: Optional[IPAddressType]=…, bind_port: Optional[int]=…, tls_standard_compatible: bool=…, happy_eyeballs_delay: float=…) -> SocketStream - removed:
async function connect_unix(path: Union[str, os.PathLike]) -> SocketStream - removed:
async function create_tcp_server(port: int=…, interface: Optional[IPAddressType]=…, ssl_context: Optional[SSLContext]=…, autostart_tls: bool=…, tls_standard_compatible: bool=…) -> SocketStreamServer - removed:
async function create_udp_socket(*, family: Union[int, AddressFamily]=…, interface: Optional[IPAddressType]=…, port: Optional[int]=…, target_host: Optional[IPAddressType]=…, target_port: Optional[int]=…, reuse_address: bool=…) -> UDPSocket - removed:
async function create_unix_server(path: Union[str, os.PathLike], *, mode: Optional[int]=…) -> SocketStreamServer - removed:
async function get_current_task() -> TaskInfo - removed:
async function get_running_tasks() -> typing.List[TaskInfo] - removed:
async function wait_all_tasks_blocked() -> None - removed:
class TaskInfo - removed:
constructor TaskInfo(id: int, parent_id: Optional[int], name: Optional[str], coro: Coroutine) - removed:
export CancelScope - removed:
export CapacityLimiter - removed:
export Condition - removed:
export Event - removed:
export IPAddressType - removed:
export Lock - removed:
export Queue - removed:
export Semaphore - removed:
export SocketStream - removed:
export SocketStreamServer - removed:
export Stream - removed:
export TaskGroup - removed:
export UDPSocket - removed:
function aopen(file: Union[str, os.PathLike, int], mode: str=…, buffering: int=…, encoding: Optional[str]=…, errors: Optional[str]=…, newline: Optional[str]=…, closefd: bool=…, opener: Optional[Callable]=…) -> Coroutine[Any, Any, AsyncFile] - removed:
function claim_worker_thread(backend) -> typing.Generator[Any, None, None] - removed:
function create_capacity_limiter(total_tokens: float) -> CapacityLimiter - removed:
function create_condition(lock: Lock=…) -> Condition - removed:
function create_event() -> Event - removed:
function create_lock() -> Lock - removed:
function create_queue(capacity: int) -> Queue - removed:
function create_semaphore(value: int) -> Semaphore - removed:
function create_task_group() -> TaskGroup - removed:
function current_default_thread_limiter() -> CapacityLimiter - removed:
function current_effective_deadline() -> Coroutine[Any, Any, float] - removed:
function current_time() -> Coroutine[Any, Any, float] - removed:
function fail_after(delay: Optional[float], *, shield: bool=…) -> typing.AsyncContextManager[CancelScope] - removed:
function finalize(resource: T_Agen) -> typing.AsyncContextManager[T_Agen] - removed:
function get_cancelled_exc_class() -> typing.Type[BaseException] - removed:
function getaddrinfo(host: Union[bytearray, bytes, str], port: Union[str, int, None], *, family: Union[int, AddressFamily]=…, type: Union[int, SocketKind]=…, proto: int=…, flags: int=…) -> Awaitable[GetAddrInfoReturnType] - removed:
function getnameinfo(sockaddr: SockaddrType, flags: int=…) -> Awaitable[Tuple[str, str]] - removed:
function move_on_after(delay: Optional[float], *, shield: bool=…) -> typing.AsyncContextManager[CancelScope] - removed:
function notify_socket_close(sock: socket.SocketType) -> Awaitable[None] - removed:
function open_cancel_scope(*, shield: bool=…) -> CancelScope - removed:
function receive_signals(*signals: int) -> typing.AsyncContextManager[typing.AsyncIterator[int]] - removed:
function run(func: Callable[..., Coroutine[Any, Any, T_Retval]], *args, backend: str=…, backend_options: Optional[Dict[str, Any]]=…) -> T_Retval - removed:
function run_async_from_thread(func: Callable[..., Coroutine[Any, Any, T_Retval]], *args) -> T_Retval - removed:
function run_in_thread(func: Callable[..., T_Retval], *args, cancellable: bool=…, limiter: Optional[CapacityLimiter]=…) -> Awaitable[T_Retval] - removed:
function sleep(delay: float) -> Coroutine[Any, Any, None] - removed:
function wait_socket_readable(sock: Union[socket.SocketType, ssl.SSLSocket]) -> Awaitable[None] - removed:
function wait_socket_writable(sock: Union[socket.SocketType, ssl.SSLSocket]) -> Awaitable[None] - removed:
variable BACKENDS - removed:
variable GetAddrInfoReturnType - removed:
variable IPPROTO_IPV6 - removed:
variable SockaddrType - removed:
variable T_Agen - removed:
variable T_Retval - added:
export BrokenResourceError - added:
export BusyResourceError - added:
export ClosedResourceError - added:
export DelimiterNotFound - added:
export EndOfStream - added:
export ExceptionGroup - added:
export IncompleteRead - added:
export TaskInfo - added:
export TypedAttributeLookupError - added:
export TypedAttributeProvider - added:
export TypedAttributeSet - added:
export WouldBlock - added:
export aclose_forcefully - added:
export connect_tcp - added:
export connect_unix - added:
export create_blocking_portal - added:
export create_capacity_limiter - added:
export create_condition - added:
export create_connected_udp_socket - added:
export create_event - added:
export create_lock - added:
export create_memory_object_stream - added:
export create_semaphore - added:
export create_task_group - added:
export create_tcp_listener - added:
export create_udp_socket - added:
export create_unix_listener - added:
export current_default_worker_thread_limiter - added:
export current_effective_deadline - added:
export current_time - added:
export fail_after - added:
export get_all_backends - added:
export get_cancelled_exc_class - added:
export get_current_task - added:
export get_running_tasks - added:
export getaddrinfo - added:
export getnameinfo - added:
export maybe_async - added:
export maybe_async_cm - added:
export move_on_after - added:
export open_cancel_scope - added:
export open_file - added:
export open_process - added:
export open_signal_receiver - added:
export run - added:
export run_async_from_thread - added:
export run_process - added:
export run_sync_in_worker_thread - added:
export sleep - added:
export start_blocking_portal - added:
export typed_attribute - added:
export wait_all_tasks_blocked - added:
export wait_socket_readable - added:
export wait_socket_writable
- removed:
async method AsyncFile.close() -> None - removed:
async method AsyncFile.flush() -> None - removed:
async method AsyncFile.read(size: int=…) -> Union[bytes, str] - removed:
async method AsyncFile.read1(size: int=…) -> Union[bytes, str] - removed:
async method AsyncFile.readinto(b: Union[bytes, memoryview]) -> bytes - removed:
async method AsyncFile.readinto1(b: Union[bytes, memoryview]) -> bytes - removed:
async method AsyncFile.readline() -> bytes - removed:
async method AsyncFile.readlines() -> bytes - removed:
async method AsyncFile.seek(offset: int, whence: Optional[int]=…) -> int - removed:
async method AsyncFile.tell() -> int - removed:
async method AsyncFile.truncate(size: Optional[int]=…) -> int - removed:
async method AsyncFile.write(b: bytes) -> None - removed:
async method AsyncFile.writelines(lines: bytes) -> None - removed:
async method CancelScope.cancel() -> None - removed:
async method CapacityLimiter.acquire() -> None - removed:
async method CapacityLimiter.acquire_nowait() -> None - removed:
async method CapacityLimiter.acquire_on_behalf_of(borrower) -> None - removed:
async method CapacityLimiter.acquire_on_behalf_of_nowait(borrower) -> None - removed:
async method CapacityLimiter.release() -> None - removed:
async method CapacityLimiter.release_on_behalf_of(borrower) -> None - removed:
async method CapacityLimiter.set_total_tokens(value: float) -> None - removed:
async method Condition.notify(n: int=…) -> None - removed:
async method Condition.notify_all() -> None - removed:
async method Condition.wait() -> None - removed:
async method Event.set() -> None - removed:
async method Event.wait() -> bool - removed:
async method Queue.get() - removed:
async method Queue.put(item) -> None - removed:
async method SocketStream.start_tls(context: Optional[SSLContext]=…) -> None - removed:
async method SocketStreamServer.accept() -> SocketStream - removed:
async method SocketStreamServer.close() -> None - removed:
async method Stream.close() -> None - removed:
async method Stream.receive_exactly(nbytes: int) -> bytes - removed:
async method Stream.receive_some(max_bytes: int) -> bytes - removed:
async method Stream.receive_until(delimiter: bytes, max_bytes: int) -> bytes - removed:
async method Stream.send_all(data: bytes) -> None - removed:
async method TaskGroup.spawn(func: Callable[..., Coroutine], *args, name=…) -> None - removed:
async method UDPSocket.close() -> None - removed:
async method UDPSocket.receive(max_bytes: int) -> Tuple[bytes, Tuple[str, int]] - removed:
async method UDPSocket.send(data: bytes, address: Optional[IPAddressType]=…, port: Optional[int]=…) -> None - removed:
class AsyncFile - removed:
class CancelScope - removed:
class CapacityLimiter - removed:
class Condition - removed:
class Event - removed:
class Lock - removed:
class Queue - removed:
class Semaphore - removed:
class SocketStream(Stream) - removed:
class SocketStreamServer - removed:
class Stream - removed:
class TaskGroup - removed:
class UDPSocket - removed:
field TaskGroup.cancel_scope - removed:
method Condition.locked() -> bool - removed:
method Event.clear() -> None - removed:
method Event.is_set() -> None - removed:
method Lock.locked() -> bool - removed:
method Queue.empty() -> bool - removed:
method Queue.full() -> bool - removed:
method Queue.qsize() -> int - removed:
method SocketStream.get_channel_binding(cb_type: str=…) -> bytes - removed:
method SocketStream.getpeercert(binary_form: bool=…) -> Union[Dict[str, Union[str, tuple]], bytes, None] - removed:
method SocketStream.getsockopt(level, optname, *args) - removed:
method SocketStream.setsockopt(level, optname, value, *args) -> None - removed:
method SocketStreamServer.accept_connections() -> AsyncIterable[SocketStream] - removed:
method SocketStreamServer.getsockopt(level, optname, *args) - removed:
method SocketStreamServer.setsockopt(level, optname, value, *args) -> None - removed:
method Stream.receive_chunks(max_size: int) -> AsyncIterable[bytes] - removed:
method Stream.receive_delimited_chunks(delimiter: bytes, max_chunk_size: int) -> AsyncIterable[bytes] - removed:
method UDPSocket.getsockopt(level, optname, *args) - removed:
method UDPSocket.receive_packets(max_size: int) -> AsyncIterable[Tuple[bytes, str]] - removed:
method UDPSocket.setsockopt(level, optname, value, *args) -> None - removed:
property CancelScope.cancel_called -> bool - removed:
property CancelScope.deadline -> float - removed:
property CancelScope.shield -> bool - removed:
property CapacityLimiter.available_tokens -> float - removed:
property CapacityLimiter.borrowed_tokens -> int - removed:
property CapacityLimiter.total_tokens -> float - removed:
property Semaphore.value -> int - removed:
property SocketStream.address -> Union[Tuple[str, int], Tuple[str, int, int, int], str] - removed:
property SocketStream.alpn_protocol -> Optional[str] - removed:
property SocketStream.cipher -> Tuple[str, str, int] - removed:
property SocketStream.peer_address -> Union[Tuple[str, int], Tuple[str, int, int, int], str] - removed:
property SocketStream.server_hostname -> Optional[str] - removed:
property SocketStream.server_side -> bool - removed:
property SocketStream.shared_ciphers -> List[Tuple[str, str, int]] - removed:
property SocketStream.tls_version -> Optional[str] - removed:
property SocketStreamServer.address -> Union[Tuple[str, int], Tuple[str, int, int, int], str] - removed:
property SocketStreamServer.port -> int - removed:
property Stream.buffered_data -> bytes - removed:
property UDPSocket.address -> Union[Tuple[str, int], Tuple[str, int, int, int]] - removed:
property UDPSocket.port -> int - removed:
variable IPAddressType - removed:
variable T_Retval - added:
export AnyByteReceiveStream - added:
export AnyByteSendStream - added:
export AnyByteStream - added:
export AnyUnreliableByteReceiveStream - added:
export AnyUnreliableByteSendStream - added:
export AnyUnreliableByteStream - added:
export AsyncResource - added:
export BlockingPortal - added:
export ByteReceiveStream - added:
export ByteSendStream - added:
export ByteStream - added:
export CancelScope - added:
export CapacityLimiter - added:
export Condition - added:
export ConnectedUDPSocket - added:
export Event - added:
export Listener - added:
export Lock - added:
export ObjectReceiveStream - added:
export ObjectSendStream - added:
export ObjectStream - added:
export Process - added:
export Semaphore - added:
export SocketAttribute - added:
export SocketListener - added:
export SocketStream - added:
export TaskGroup - added:
export TestRunner - added:
export UDPSocket - added:
export UnreliableObjectReceiveStream - added:
export UnreliableObjectSendStream - added:
export UnreliableObjectStream
- added:
async method AsyncResource.aclose() -> None - added:
class AsyncResource
- added:
async method SocketListener.accept() -> SocketStream[T_SockAddr] - added:
async method SocketListener.serve(handler: Callable[[T_Stream], Any], task_group: Optional[TaskGroup]=…) -> None - added:
async method UDPSocket.sendto(data: bytes, host: str, port: int) -> None - added:
class ConnectedUDPSocket(UnreliableObjectStream[bytes], _SocketProvider[IPSockAddrType]) - added:
class SocketAttribute(TypedAttributeSet) - added:
class SocketListener(Generic[T_SockAddr], Listener[SocketStream[T_SockAddr]], _SocketProvider[T_SockAddr]) - added:
class SocketStream(Generic[T_SockAddr], ByteStream, _SocketProvider[T_SockAddr]) - added:
class UDPSocket(UnreliableObjectStream[UDPPacketType], _SocketProvider[IPSockAddrType]) - added:
field SocketAttribute.family: AddressFamily - added:
field SocketAttribute.local_address: SockAddrType - added:
field SocketAttribute.local_port: int - added:
field SocketAttribute.raw_socket: SocketType - added:
field SocketAttribute.remote_address: SockAddrType - added:
field SocketAttribute.remote_port: int - added:
variable IPAddressType - added:
variable IPSockAddrType - added:
variable SockAddrType - added:
variable T_Retval - added:
variable T_SockAddr - added:
variable UDPPacketType
- added:
async method ByteReceiveStream.receive(max_bytes: int=…) -> bytes - added:
async method ByteSendStream.send(item: bytes) -> None - added:
async method ByteStream.send_eof() -> None - added:
async method Listener.serve(handler: Callable[[T_Stream], Any], task_group: Optional[TaskGroup]=…) -> None - added:
async method ObjectStream.send_eof() -> None - added:
async method UnreliableObjectReceiveStream.receive() -> T_Item - added:
async method UnreliableObjectSendStream.send(item: T_Item) -> None - added:
class ByteReceiveStream(AsyncResource, TypedAttributeProvider) - added:
class ByteSendStream(AsyncResource, TypedAttributeProvider) - added:
class ByteStream(ByteReceiveStream, ByteSendStream) - added:
class Listener(Generic[T_Stream], AsyncResource, TypedAttributeProvider) - added:
class ObjectReceiveStream(Generic[T_Item], UnreliableObjectReceiveStream[T_Item]) - added:
class ObjectSendStream(Generic[T_Item], UnreliableObjectSendStream[T_Item]) - added:
class ObjectStream(Generic[T_Item], ObjectReceiveStream[T_Item], ObjectSendStream[T_Item], UnreliableObjectStream[T_Item]) - added:
class UnreliableObjectReceiveStream(Generic[T_Item], AsyncResource, TypedAttributeProvider) - added:
class UnreliableObjectSendStream(Generic[T_Item], AsyncResource, TypedAttributeProvider) - added:
class UnreliableObjectStream(Generic[T_Item], UnreliableObjectReceiveStream[T_Item], UnreliableObjectSendStream[T_Item]) - added:
variable AnyByteReceiveStream - added:
variable AnyByteSendStream - added:
variable AnyByteStream - added:
variable AnyUnreliableByteReceiveStream - added:
variable AnyUnreliableByteSendStream - added:
variable AnyUnreliableByteStream - added:
variable T_Item - added:
variable T_Stream
- added:
async method Process.wait() -> int - added:
class Process(AsyncResource) - added:
method Process.kill() -> None - added:
method Process.send_signal(signal: int) -> None - added:
method Process.terminate() -> None - added:
property Process.pid -> int - added:
property Process.returncode -> Optional[int] - added:
property Process.stderr -> Optional[ByteReceiveStream] - added:
property Process.stdin -> Optional[ByteSendStream] - added:
property Process.stdout -> Optional[ByteReceiveStream]
- added:
async method CapacityLimiter.acquire() -> None - added:
async method CapacityLimiter.acquire_nowait() -> None - added:
async method CapacityLimiter.acquire_on_behalf_of(borrower) -> None - added:
async method CapacityLimiter.acquire_on_behalf_of_nowait(borrower) -> None - added:
async method CapacityLimiter.release() -> None - added:
async method CapacityLimiter.release_on_behalf_of(borrower) -> None - added:
async method CapacityLimiter.set_total_tokens(value: float) -> None - added:
async method Condition.acquire() -> None - added:
async method Condition.notify(n: int=…) -> None - added:
async method Condition.notify_all() -> None - added:
async method Condition.release() -> None - added:
async method Condition.wait() -> None - added:
async method Event.set() -> None - added:
async method Event.wait() -> bool - added:
async method Lock.acquire() -> None - added:
async method Lock.release() -> None - added:
async method Semaphore.acquire() -> None - added:
async method Semaphore.release() -> None - added:
class CapacityLimiter - added:
class Condition - added:
class Event - added:
class Lock - added:
class Semaphore - added:
method Condition.locked() -> bool - added:
method Event.is_set() -> bool - added:
method Lock.locked() -> bool - added:
property CapacityLimiter.available_tokens -> float - added:
property CapacityLimiter.borrowed_tokens -> int - added:
property CapacityLimiter.total_tokens -> float - added:
property Semaphore.value -> int - added:
variable IPAddressType - added:
variable T_Retval
- added:
async method CancelScope.cancel() -> None - added:
async method TaskGroup.spawn(func: Callable[..., Coroutine], *args, name=…) -> None - added:
class CancelScope - added:
class TaskGroup - added:
field TaskGroup.cancel_scope: CancelScope - added:
property CancelScope.cancel_called -> bool - added:
property CancelScope.deadline -> float - added:
property CancelScope.shield -> bool - added:
variable T_Retval
- added:
async method BlockingPortal.sleep_until_stopped() -> None - added:
async method BlockingPortal.stop(cancel_remaining: bool=…) -> None - added:
class BlockingPortal - added:
constructor BlockingPortal() - added:
method BlockingPortal.call(func: Callable[..., Coroutine[Any, Any, T_Retval]], *args) -> T_Retval | (func: Callable[..., T_Retval], *args) -> T_Retval - added:
method BlockingPortal.spawn_task(func: Callable[..., Coroutine], *args) -> Future - added:
method BlockingPortal.stop_from_external_thread(cancel_remaining: bool=…) -> None - added:
method BlockingPortal.wrap_async_context_manager(cm: AsyncContextManager[T_co]) -> ContextManager[T_co] - added:
variable T_Retval - added:
variable T_co
- removed:
class ClosedResourceError(Exception) - removed:
class DelimiterNotFound(Exception) - removed:
class ExceptionGroup(BaseException) - removed:
class IncompleteRead(Exception) - removed:
class ResourceBusyError(Exception) - removed:
class TLSRequired(Exception) - removed:
class WouldBlock(Exception) - removed:
constructor DelimiterNotFound(max_bytes: int) -> None - removed:
constructor IncompleteRead() -> None - removed:
constructor ResourceBusyError(action: str) - removed:
field ExceptionGroup.SEPARATOR - removed:
field ExceptionGroup.exceptions
- removed:
function pytest_addoption(parser) - removed:
function pytest_generate_tests(metafunc) - added:
function anyio_backend(request) - added:
function extract_backend_and_options(backend) -> Tuple[str, Dict[str, Any]] - added:
function get_runner(backend_name: str, backend_options: Dict[str, Any]) -> Iterator[TestRunner] - added:
function pytest_pycollect_makeitem(collector, name, obj)
- added:
async method BufferedByteReceiveStream.aclose() -> None - added:
async method BufferedByteReceiveStream.receive(max_bytes: int=…) -> bytes - added:
async method BufferedByteReceiveStream.receive_exactly(nbytes: int) -> bytes - added:
async method BufferedByteReceiveStream.receive_until(delimiter: bytes, max_bytes: int) -> bytes - added:
class BufferedByteReceiveStream(ByteReceiveStream) - added:
field BufferedByteReceiveStream.receive_stream: AnyByteReceiveStream - added:
property BufferedByteReceiveStream.buffer -> bytes - added:
property BufferedByteReceiveStream.extra_attributes
- added:
async method MemoryObjectReceiveStream.aclose() -> None - added:
async method MemoryObjectReceiveStream.receive() -> T_Item - added:
async method MemoryObjectReceiveStream.receive_nowait() -> T_Item - added:
async method MemoryObjectSendStream.aclose() -> None - added:
async method MemoryObjectSendStream.send(item: T_Item) -> None - added:
async method MemoryObjectSendStream.send_nowait(item: T_Item) -> None - added:
class MemoryObjectReceiveStream(Generic[T_Item], ObjectReceiveStream[T_Item]) - added:
class MemoryObjectSendStream(Generic[T_Item], ObjectSendStream[T_Item]) - added:
class MemoryObjectStreamState(Generic[T_Item]) - added:
field MemoryObjectStreamState.buffer: Deque[T_Item] - added:
field MemoryObjectStreamState.max_buffer_size: float - added:
field MemoryObjectStreamState.open_receive_channels: int - added:
field MemoryObjectStreamState.open_send_channels: int - added:
field MemoryObjectStreamState.waiting_receivers: OrderedDict[Event, List[T_Item]] - added:
field MemoryObjectStreamState.waiting_senders: OrderedDict[Event, T_Item] - added:
method MemoryObjectReceiveStream.clone() -> MemoryObjectReceiveStream - added:
method MemoryObjectSendStream.clone() -> MemoryObjectSendStream - added:
variable T_Item
- added:
async method MultiListener.aclose() -> None - added:
async method MultiListener.serve(handler: Callable[[T_Stream], Any], task_group: Optional[TaskGroup]=…) -> None - added:
async method StapledByteStream.aclose() -> None - added:
async method StapledByteStream.receive(max_bytes: int=…) -> bytes - added:
async method StapledByteStream.send(item: bytes) -> None - added:
async method StapledByteStream.send_eof() -> None - added:
async method StapledObjectStream.aclose() -> None - added:
async method StapledObjectStream.receive() -> T_Item - added:
async method StapledObjectStream.send(item: T_Item) -> None - added:
async method StapledObjectStream.send_eof() -> None - added:
class MultiListener(Generic[T_Stream], Listener[T_Stream]) - added:
class StapledByteStream(ByteStream) - added:
class StapledObjectStream(Generic[T_Item], ObjectStream[T_Item]) - added:
field MultiListener.listeners: Sequence[Listener[T_Stream]] - added:
field StapledByteStream.receive_stream: ByteReceiveStream - added:
field StapledByteStream.send_stream: ByteSendStream - added:
field StapledObjectStream.receive_stream: ObjectReceiveStream[T_Item] - added:
field StapledObjectStream.send_stream: ObjectSendStream[T_Item] - added:
property MultiListener.extra_attributes - added:
property StapledByteStream.extra_attributes - added:
property StapledObjectStream.extra_attributes - added:
variable T_Item - added:
variable T_Stream
- added:
async method TextReceiveStream.aclose() -> None - added:
async method TextReceiveStream.receive() -> str - added:
async method TextSendStream.aclose() -> None - added:
async method TextSendStream.send(item: str) -> None - added:
async method TextStream.aclose() -> None - added:
async method TextStream.receive() -> str - added:
async method TextStream.send(item: str) -> None - added:
async method TextStream.send_eof() -> None - added:
class TextReceiveStream(ObjectReceiveStream[str]) - added:
class TextSendStream(ObjectSendStream[str]) - added:
class TextStream(ObjectStream[str]) - added:
field TextReceiveStream.encoding: InitVar[str] - added:
field TextReceiveStream.errors: InitVar[str] - added:
field TextReceiveStream.transport_stream: AnyByteReceiveStream - added:
field TextSendStream.encoding: InitVar[str] - added:
field TextSendStream.errors: str - added:
field TextSendStream.transport_stream: AnyByteSendStream - added:
field TextStream.encoding: InitVar[str] - added:
field TextStream.errors: InitVar[str] - added:
field TextStream.transport_stream: AnyByteStream - added:
property TextReceiveStream.extra_attributes - added:
property TextSendStream.extra_attributes - added:
property TextStream.extra_attributes
- added:
async method TLSListener.aclose() -> None - added:
async method TLSListener.serve(handler: Callable[[TLSStream], Any], task_group: Optional[TaskGroup]=…) -> None - added:
async method TLSStream.aclose() -> None - added:
async method TLSStream.receive(max_bytes: int=…) -> bytes - added:
async method TLSStream.send(item: bytes) -> None - added:
async method TLSStream.send_eof() -> None - added:
async method TLSStream.unwrap() -> Tuple[AnyByteStream, bytes] - added:
async static method TLSListener.handle_handshake_error(exc: BaseException, stream: AnyByteStream) -> None - added:
async static method TLSStream.wrap(transport_stream: AnyByteStream, *, server_side: Optional[bool]=…, hostname: Optional[str]=…, ssl_context: Optional[ssl.SSLContext]=…, standard_compatible: bool=…) -> TLSStream - added:
class TLSAttribute(TypedAttributeSet) - added:
class TLSListener(Listener[TLSStream]) - added:
class TLSStream(ByteStream) - added:
field TLSAttribute.alpn_protocol: Optional[str] - added:
field TLSAttribute.channel_binding_tls_unique: bytes - added:
field TLSAttribute.cipher: Tuple[str, str, int] - added:
field TLSAttribute.peer_certificate: Optional[Dict[str, Union[str, tuple]]] - added:
field TLSAttribute.peer_certificate_binary: Optional[bytes] - added:
field TLSAttribute.server_side: bool - added:
field TLSAttribute.shared_ciphers: List[Tuple[str, str, int]] - added:
field TLSAttribute.ssl_object: ssl.SSLObject - added:
field TLSAttribute.standard_compatible: bool - added:
field TLSAttribute.tls_version: str - added:
field TLSListener.handshake_timeout: float - added:
field TLSListener.listener: Listener - added:
field TLSListener.ssl_context: ssl.SSLContext - added:
field TLSListener.standard_compatible: bool - added:
field TLSStream.standard_compatible: bool - added:
field TLSStream.transport_stream: AnyByteStream - added:
property TLSListener.extra_attributes - added:
property TLSStream.extra_attributes - added:
variable T_Retval