o #6÷dîã@szddlmZddlZddlmZmZmZddlmZm Z m Z edƒZ e ddd d „ƒZ e dddd „ƒZ dddd „Z dS)é)Ú annotationsN)ÚAnyÚTypeVarÚoverloadé)ÚMemoryObjectReceiveStreamÚMemoryObjectSendStreamÚMemoryObjectStreamStateÚT_Item.Úmax_buffer_sizeÚfloatÚreturnúBtuple[MemoryObjectSendStream[Any], MemoryObjectReceiveStream[Any]]cCódS©N©)r rrúkC:\Users\jesus\OneDrive\Desktop\erpjis_fastapi\backend\jisbackend\Lib\site-packages\anyio/_core/_streams.pyÚcreate_memory_object_streamórÚ item_typeú type[T_Item]úHtuple[MemoryObjectSendStream[T_Item], MemoryObjectReceiveStream[T_Item]]cCrrr)r rrrrrrútype[T_Item] | NonecCsD|tjkrt|tƒstdƒ‚|dkrtdƒ‚t|ƒ}t|ƒt|ƒfS)aI Create a memory object stream. :param max_buffer_size: number of items held in the buffer until ``send()`` starts blocking :param item_type: type of item, for marking the streams with the right generic type for static typing (not used at run time) :return: a tuple of (send stream, receive stream) z5max_buffer_size must be either an integer or math.infrz"max_buffer_size cannot be negative)ÚmathÚinfÚ isinstanceÚintÚ ValueErrorr rr)r rÚstaterrrrs  ).)r r r r)..)r r rrr r)rN)r r rrr r) Ú __future__rrÚtypingrrrZstreams.memoryrrr r rrrrrÚs ÿÿÿ