Ë
    €Ï7  ã                   óJ   — d dl mZmZ d dlmZmZ d dlmZ  G d„ dee¬«      Zy)é    )ÚabstractmethodÚABCMeta)ÚAsyncContextManagerÚSet)Ú	Partitionc                   ó,   — e Zd ZdZedee   fd„«       Zy)ÚAssignerz±
    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              ƒ   ó   K  — t        «       ‚­w)N)ÚNotImplementedError)Úselfs    úAlib/third_party/google/cloud/pubsublite/internal/wire/assigner.pyÚget_assignmentzAssigner.get_assignment   s   è ø€ ä!Ó#Ð#ùs   ‚N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   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   