Ë €ÏÒãód—ddlmZddlmZmZddlmZddlmZm Z m Z Gd„dee e fe¬«Z y) é)ÚGeneric)ÚABCMetaÚabstractmethod)ÚGoogleAPICallError)Ú ConnectionÚRequestÚResponsecóF—eZdZdZedefd„«Zedeee ffd„«Z y)ÚConnectionReinitializerzPA class capable of reinitializing a connection after a new one has been created.ÚerrorcƒóK—t«‚­w)z¶Tear down internal state processing the current connection in response to a stream error. Args: error: The error that caused the stream to break ©ÚNotImplementedError)Úselfr s úQlib/third_party/google/cloud/pubsublite/internal/wire/connection_reinitializer.pyÚstop_processingz'ConnectionReinitializer.stop_processingsèø€ô"Ó#Ð#ùó‚ Ú connectioncƒóK—t«‚­w)aReinitialize a connection. Must ensure no calls to the associated RetryingConnection occur until this completes. Args: connection: The connection to reinitialize Raises: GoogleAPICallError: If it fails to reinitialize. r)rrs rÚ reinitializez$ConnectionReinitializer.reinitialize&sèø€ô"Ó#Ð#ùrN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrrrr r©órr r sE„ÙZàð$Ð+=ò$óð$ðð $à˜w¨Ð0Ñ1ò $óñ $rr )Ú metaclassN) ÚtypingrÚabcrrÚgoogle.api_core.exceptionsrÚ0google.cloud.pubsublite.internal.wire.connectionrrr r rrrÚr"s2ðõß'Ý9÷ñô$˜g g¨xÐ&7Ñ8ÀGö$r