ddlmZmZmZddlmZmZedZedZGddedeeefeZ Gdd eeefeZ y ) )GenericTypeVarAsyncContextManager)abstractmethodABCMetaRequestResponsec@eZdZdZededdfdZedefdZy) Connectionze A connection to an underlying stream. Only one call to 'read' may be outstanding at a time. requestreturnNcKtw)z Write a message to the stream. Raises: GoogleAPICallError: When the connection terminates in failure. NotImplementedError)selfr s Clib/third_party/google/cloud/pubsublite/internal/wire/connection.pywritezConnection.write"## cKtw)z Read a message off of the stream. Raises: GoogleAPICallError: When the connection terminates in failure. rrs rreadzConnection.read'rr) __name__ __module__ __qualname____doc__rrrr rrr r sD$7$t$$$H$$rr ) metaclassc0eZdZdZedeeeffdZy)ConnectionFactoryz$A factory for producing Connections.r cKtw)Nrrs rnewzConnectionFactory.new5s!##rN) rrrrrr rr r#rrrr!r!2s(.$:gx&78$$rr!N) typingrrrabcrrrr r r!rrrr&s\98' )  : $ %ww/@'AW$8$ 12g$r