o :ήcÖã @sÒddlZddlmZmZmZmZmZmZddlm Z m Z m Z edƒZ ede dee dee e e e ffd d „ƒZe d de dee ee effd d „ƒZ dde deee dee ee effd d „ZdS)éN)ÚAnyÚOptionalÚTupleÚTypeÚTypeVarÚoverloadé)ÚMemoryObjectReceiveStreamÚMemoryObjectSendStreamÚMemoryObjectStreamStateÚT_ItemÚmax_buffer_sizeÚ item_typeÚreturncCódS©N©)r rrrú;/tmp/pip-target-vg8gfxp4/lib/python/anyio/_core/_streams.pyÚcreate_memory_object_stream órcCrrr)r rrrrrcCsD|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 r r )r rÚstaterrrrs  )r)rN)rÚtypingrrrrrrÚstreams.memoryr r r r ÚfloatrrrrrÚs6 ÿÿ þÿÿ þÿÿ ÿþ