U
    cc                     @   sX   d dl mZ d dlmZ ddl mZ ddlmZ G dd dejZ	G dd dej
Zd	S )
   )AsyncConnectable)AsyncSession   )eventsc                   @   s.   e Zd ZdZeZedd ZedddZdS )	AsyncConnectionEventsZ
SomeEnginec                 C   s   t dd S )Nzasynchronous events are not implemented at this time.  Apply synchronous listeners to the AsyncEngine.sync_engine or AsyncConnection.sync_connection attributes.NotImplementedErrorcls r   A/tmp/pip-unpacked-wheel-8u86ls_i/sqlalchemy/ext/asyncio/events.py_no_async_engine_events   s    z-AsyncConnectionEvents._no_async_engine_eventsFc                 C   s   |    d S Nr   r
   Z	event_keyretvalr   r   r   _listen   s    zAsyncConnectionEvents._listenN)F)	__name__
__module____qualname___target_class_docr   _dispatch_targetclassmethodr   r   r   r   r   r   r      s   
r   c                   @   s.   e Zd ZdZeZedd ZedddZdS )	AsyncSessionEventsZSomeSessionc                 C   s   t dd S )Nztasynchronous events are not implemented at this time.  Apply synchronous listeners to the AsyncSession.sync_session.r   r	   r   r   r   r   #   s    z*AsyncSessionEvents._no_async_engine_eventsFc                 C   s   |    d S r   r   r   r   r   r   r   *   s    zAsyncSessionEvents._listenN)F)	r   r   r   r   r   r   r   r   r   r   r   r   r   r      s   
r   N)Zenginer   sessionr   r   Zengine_eventZormZ	orm_eventZConnectionEventsr   ZSessionEventsr   r   r   r   r   <module>   s
   