8'hW%2ddlmZdZGddeZGddeZGddeZGd d eZGd d eZGd deZ Gdde Z Gdde Z Gdde Z Gdde Z Gdde ZGdde ZGdde Zy))absolute_import) Publication SubscriptionHandler RegistrationEndpointPublishRequestSubscribeRequestUnsubscribeRequest CallRequestInvocationRequestRegisterRequestUnregisterRequestc eZdZdZdZdZdZy)rzw Object representing a publication (feedback from publishing an event when doing an acknowledged publish). id was_encryptedc ||_||_y)z :param publication_id: The publication ID of the published event. :type publication_id: int :param was_encrypted: Flag indicating whether the app payload was encrypted. :type was_encrypted: bool Nr)selfpublication_idrs Q/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/wamp/request.py__init__zPublication.__init__6s!*cNdj|j|jS)Nz&Publication(id={0}, was_encrypted={1}))formatrrrs r__str__zPublication.__str__Bs7>>twwHZHZ[[rN)__name__ __module__ __qualname____doc__ __slots__rrrrrr.s (I +\rrc&eZdZdZdZdZdZdZy)rz5 Object representing a handler subscription. rtopicactivesessionhandlercJ||_||_d|_||_||_y)a :param subscription_id: The subscription ID. :type subscription_id: int :param topic: The subscription URI or URI pattern. :type topic: str :param session: The ApplicationSession this subscription is living on. :type session: instance of ApplicationSession :param handler: The user event callback. :type handler: callable TNr%)rsubscription_idr&r(r)s rrzSubscription.__init__Ms'"    rcf|jr|jj|Std)z0 Unsubscribe this subscription. zsubscription no longer active)r'r( _unsubscribe Exceptionrs r unsubscribezSubscription.unsubscribebs, ;;<<,,T2 2;< r?s rrzRegistration.__init__s'"  "  rcf|jr|jj|Std) zregistration no longer active)r'r( _unregisterr.rs r unregisterzRegistration.unregisters, ;;<<++D1 1;< optionscNtj|||||_||_y)a: :param request_id: The WAMP request ID. :type request_id: int :param on_reply: The Deferred/Future to be fired when the request returns. :type on_reply: Deferred/Future :param options: WAMP call options that are in use for this call. :type options: dict N)rIrr>rX)rrKr>rLrXs rrzCallRequest.__init__ s$ z84" rNr:r#rrr r s*Irr ceZdZdZy)r zK Object representing an outstanding request to invoke an endpoint. N)rrr r!r#rrr r 1srr ceZdZdZdZdZy)rzM Object representing an outstanding request to register a procedure. )r>r?cNtj|||||_||_yrT)rIrr>r?)rrKrLr>r?s rrzRegisterRequest.__init__>s$ z84"  rNr:r#rrrr7s+I!rrceZdZdZdZdZy)rzR Object representing an outstanding request to unregister a registration. )rAc@tj|||||_yrT)rIrrA)rrKrLrAs rrzUnregisterRequest.__init__MrUrNr:r#rrrrFrVrrN) __future__r__all__objectrrrrrrIr r r r r rrr#rrrbs8'  \&\0&R6&RR'f'0"=6"=J'v'0!f!*+W+.w6 / /'0 !g ! / /r