hddlmZmZddlmZmZmZddlmZGddeeZ GddeeZ y ) )abstractmethodABCMeta)AsyncContextManagerMappingContextManager)futuresc @eZdZdZe ddededeeefdefdZy) 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_keyattrsreturncKtw)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 r s Plib/third_party/google/cloud/pubsublite/cloudpubsub/internal/single_publisher.pypublishzAsyncSinglePublisher.publishs$"##s N __name__ __module__ __qualname____doc__rbytesstrrrrr r sG/1$$),$r(s0(??$.'$:$n$r