U Rh@spddlmZddlZddlmZmZddlmZddlm Z m Z m Z edZ Gdd d ee e e e fZ dS) ) annotationsN)TupleTypeVar)warn)MemoryObjectReceiveStreamMemoryObjectSendStreamMemoryObjectStreamStateT_Itemc@s$eZdZdZd dddddd ZdS) create_memory_object_streama Create a memory object stream. The stream's item type can be annotated like :func:`create_memory_object_stream[T_Item]`. :param max_buffer_size: number of items held in the buffer until ``send()`` starts blocking :param item_type: old way of marking the streams with the right generic type for static typing (does nothing on AnyIO 4) .. deprecated:: 4.0 Use ``create_memory_object_stream[YourItemType](...)`` instead. :return: a tuple of (send stream, receive stream) rNfloatobjectzHtuple[MemoryObjectSendStream[T_Item], MemoryObjectReceiveStream[T_Item]])max_buffer_size item_typereturncCs^|tjkrt|tstd|dkr,td|dk rBtdtddtt|}t |t |fS)Nz5max_buffer_size must be either an integer or math.infrz"max_buffer_size cannot be negativeztThe item_type argument has been deprecated in AnyIO 4.0. Use create_memory_object_stream[YourItemType](...) instead.r) stacklevel) mathinf isinstanceint ValueErrorrDeprecationWarningr r rr)clsrrstater:./venv/lib/python3.8/site-packages/anyio/_core/_streams.py__new__$s z#create_memory_object_stream.__new__)rN)__name__ __module__ __qualname____doc__rrrrrr sr )Z __future__rrtypingrrwarningsrZstreams.memoryrrr r r rrrrs