ó
    €Ï7  ã                   óD   • S SK JrJr  S SKJrJr  S SKJr   " S S\\S9rg)é    )ÚabstractmethodÚABCMeta)ÚAsyncContextManagerÚSet)Ú	Partitionc                   ó6   • \ rS rSrSr\S\\   4S j5       rSr	g)ÚAssigneré   z¥
An assigner will deliver a continuous stream of assignments when called into. Perform all necessary work with the
assignment before attempting to get the next one.
Úreturnc              ƒ   ó   #   • [        5       e7f)N)ÚNotImplementedError)Úselfs    ÚAlib/third_party/google/cloud/pubsublite/internal/wire/assigner.pyÚget_assignmentÚAssigner.get_assignment   s   é € ä!Ó#Ð#ùs   ‚© N)
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r   r   r   Ú__static_attributes__r   ó    r   r	   r	      s&   † ñð
 ð$ c¨)¡nó $ó ó$r   r	   )Ú	metaclassN)	Úabcr   r   Útypingr   r   Ú'google.cloud.pubsublite.types.partitionr   r	   r   r   r   Ú<module>r      s   ð÷ (ß +å =ô$Ð"¨gó $r   