dSSKJrJr SSKJr SSKJr SSKJr SSK J r SSK J r SSK JrJr SSKJr SS KJrJr SS KJr SS KJr SS KJr \rSS\S\S\\S\\S\\S\\\\4S\\S\4SjjrSS\S\S\\S\\S\\S\\\\4S\\S\4Sjjrg ))OptionalMapping) ClientOptions) Credentials) BatchSettings)AsyncSinglePublisherImpl)SinglePublisherImpl)AsyncSinglePublisherSinglePublisher)PublisherClientId)make_publisherDEFAULT_BATCHING_SETTINGS)merge_metadata)pubsub_context) TopicPathNtopic transportper_partition_batching_settings credentialsclient_optionsmetadata client_idreturncd^^^^^^^[[SS9T5mUUUUUUU4Sjn[U5$)a Make a new publisher for the given topic. Args: topic: The topic to publish to. transport: The transport type to use. per_partition_batching_settings: Settings for batching messages on each partition. The default is reasonable for most cases. credentials: The credentials to use to connect. GOOGLE_DEFAULT_CREDENTIALS is used if None. client_options: Other options to pass to the client. Note that if you pass any you must set api_endpoint. metadata: Additional metadata to send with the RPC. client_id: 128-bit unique client id. If set, enables publish idempotency for the session. Returns: A new AsyncPublisher. Throws: GoogleApiCallException on any error determining topic structure. CLOUD_PUBSUB_SHIM) frameworkc ">[TTTTTTTS9$)Nrrrrrrr)make_wire_publisher)rrrrrrrsNlib/third_party/google/cloud/pubsublite/cloudpubsub/internal/make_publisher.pyunderlying_factory0make_async_publisher..underlying_factoryIs%",K#)  )rrr)rrrrrrrr!s``````` r make_async_publisherr$,s/6n7JKXVH    $$6 77r#c 2[[UUUUUUUS95$)a Make a new publisher for the given topic. Args: topic: The topic to publish to. transport: The transport type to use. per_partition_batching_settings: Settings for batching messages on each partition. The default is reasonable for most cases. credentials: The credentials to use to connect. GOOGLE_DEFAULT_CREDENTIALS is used if None. client_options: Other options to pass to the client. Note that if you pass any you must set api_endpoint. metadata: Additional metadata to send with the RPC. client_id: 128-bit unique client id. If set, enables publish idempotency for the session. Returns: A new Publisher. Throws: GoogleApiCallException on any error determining topic structure. r)r r$rs r r r Ws.6 ,K#)   r#)NNNNN)typingrrgoogle.api_core.client_optionsrgoogle.auth.credentialsrgoogle.cloud.pubsub_v1.typesrAgoogle.cloud.pubsublite.cloudpubsub.internal.async_publisher_implr;google.cloud.pubsublite.cloudpubsub.internal.publisher_implr =google.cloud.pubsublite.cloudpubsub.internal.single_publisherr r 4google.cloud.pubsublite.internal.publisher_client_idr 4google.cloud.pubsublite.internal.wire.make_publisherr rrWIRE_DEFAULT_BATCHING4google.cloud.pubsublite.internal.wire.merge_metadatar4google.cloud.pubsublite.internal.wire.pubsub_contextrgoogle.cloud.pubsublite.typesrstrr$r#r r5sP%8/6SPO32 @D)-.2,0-1(8 (8(8&.m%<(8+& (8 ]+ (8 wsCx() (8)*(8(8\@D)-.2,0-1% %%&.m%<%+& % ]+ % wsCx() %)*%%r#