\SSKJrJr SSKJrJrJr SSKJr "SS\\S9r "SS\\S9r g ) )abstractmethodABCMeta)AsyncContextManagerMappingContextManager)futuresc L\rSrSrSr\S S\S\S\\\4S\4Sjj5r Sr g ) AsyncSinglePublisherz An AsyncPublisher publishes messages similar to Google Pub/Sub, but must be used in an async context. Any publish failures are permanent. Must be used in an `async with` block or have __aenter__() awaited before use. data ordering_keyattrsreturnc# [5e7f)a; Publish a message. Args: 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. NotImplementedErrorselfr r rs Plib/third_party/google/cloud/pubsublite/cloudpubsub/internal/single_publisher.pypublishAsyncSinglePublisher.publishs$"##s N __name__ __module__ __qualname____firstlineno____doc__rbytesstrrr__static_attributes__rrr r sG/1$$),$r.s0(??$.'$:$n$r$