܈h SSKJr SSKrSSKJr SSKJr SSKJrJ r J r \"S5r "SS \ \ \ \\ 45r g) ) annotationsN)TypeVar)warn)MemoryObjectReceiveStreamMemoryObjectSendStreamMemoryObjectStreamStateT_Itemc2\rSrSrSrSSSjjrSrg)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) NcU[R:wa [U[5(d [ S5eUS:a [ S5eUb[ S[ SS9 [["U5n[U5[U54$)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)clsmax_buffer_size item_typestates BQ#Q4:Q QQQrr ) __future__rrtypingrwarningsrstreams.memoryrrr r tupler rrrr-sL"   $Q  (*CF*K KL$Qr