ó €ÏÒãó^•SSKJr SSKJrJr SSKJr SSKJrJ r J r "SS\\ \ 4\S9r g) é)ÚGeneric)ÚABCMetaÚabstractmethod)ÚGoogleAPICallError)Ú ConnectionÚRequestÚResponsecóR•\rSrSrSr\S\4Sj5r\S\\ \ 44Sj5r Sr g) ÚConnectionReinitializerézPA class capable of reinitializing a connection after a new one has been created.Úerrorcƒó# •[5e7f)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_processingÚ'ConnectionReinitializer.stop_processingsé€ô"Ó#Ð#ùó‚ Ú connectioncƒó# •[5e7f)zåReinitialize 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Ú reinitializeÚ$ConnectionReinitializer.reinitialize&sé€ô"Ó#Ð#ùr©N) Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__rrrrrr rÚ__static_attributes__rórr r sE†ÙZàð$Ð+=ó$óð$ðð $à˜w¨Ð0Ñ1ó $óó $r!r )Ú metaclassN) ÚtypingrÚabcrrÚgoogle.api_core.exceptionsrÚ0google.cloud.pubsublite.internal.wire.connectionrrr r rr!rÚr's2ðõß'Ý9÷ñô$˜g g¨xÐ&7Ñ8ÀGó$r!