SSKJrJrJr SSKJrJr \"S5r\"S5r"SS\S\\\4\S9r "SS \\\4\S9r g ) )GenericTypeVarAsyncContextManager)abstractmethodABCMetaRequestResponsecL\rSrSrSr\S\SS4Sj5r\S\4Sj5r Sr g) Connectionz] A connection to an underlying stream. Only one call to 'read' may be outstanding at a time. requestreturnNc# [5e7f)zj 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.pywriteConnection.write"## c# [5e7f)zm Read a message off of the stream. Raises: GoogleAPICallError: When the connection terminates in failure. rrs rreadConnection.read'rr) __name__ __module__ __qualname____firstlineno____doc__rrrr r__static_attributes__rrr r sD$7$t$$$H$$r#r ) metaclassc:\rSrSrSr\S\\\44Sj5r Sr g)ConnectionFactory2z$A factory for producing Connections.rc# [5e7f)Nrrs rnewConnectionFactory.new5s!##rrN) rrrr r!rr rr r)r"rr#rr&r&2s(.$:gx&78$$r#r&N) typingrrrabcrrrr r r&rr#rr-s\98' )  : $ %ww/@'AW$8$ 12g$r#