lSSKJrJr SSKJr SSKJrJrJrJ r SSK J r "SS\ \S9r "SS \\S9r g ) )abstractmethodABCMeta)Future)ContextManagerMappingUnionAsyncContextManager) TopicPathc Z\rSrSrSr\S S\\\4S\ S\S\ \\4S\4 Sjj5r S r g ) AsyncPublisherClientInterfacez An AsyncPublisherClientInterface publishes messages similar to Google Pub/Sub, but must be used in an async context. Any publish failures are unlikely to succeed if retried. Must be used in an `async with` block or have __aenter__() awaited before use. topicdata ordering_keyattrsreturnc# [5e7f)a Publish a message. Args: topic: The topic to publish to. Publishes to new topics may have nontrivial startup latency. data: The bytestring payload of the message ordering_key: The key to enforce ordering on, or "" for no ordering. **attrs: Additional attributes to send. Returns: An ack id, which can be decoded using MessageMetadata.decode. Raises: GoogleApiCallError: On a permanent failure. NotImplementedErrorselfrrrrs Qlib/third_party/google/cloud/pubsublite/cloudpubsub/publisher_client_interface.pypublish%AsyncPublisherClientInterface.publishs."##s N __name__ __module__ __qualname____firstlineno____doc__rrr strbytesrr__static_attributes__rrr r sb  $Y^$$$ $ c" $ $$r'r ) metaclassc Z\rSrSrSr\S S\\\4S\ S\S\ \\4SS4 S jj5r S r g ) PublisherClientInterface8z A PublisherClientInterface publishes messages similar to Google Pub/Sub. Any publish failures are unlikely to succeed if retried. Must be used in a `with` block or have __enter__() called before use. rrrrrz Future[str]c [5e)a Publish a message. Args: topic: The topic to publish to. Publishes to new topics may have nontrivial startup latency. data: The bytestring payload of the message ordering_key: The key to enforce ordering on, or "" for no ordering. **attrs: Additional attributes to send. Returns: A future completed with an ack id of type str, which can be decoded using MessageMetadata.decode. Raises: GoogleApiCallError: On a permanent failure. rrs rr PublisherClientInterface.publish@s 0"##r'rNrrrr'rr*r*8sb  $Y^$$$ $ c" $  $$r'r*N)abcrrconcurrent.futuresrtypingrrrr google.cloud.pubsublite.typesr r r*rr'rr2s4(%FF3$$77$D $~ $r'