HNddlmZddlmZddlmZddlmZmZGddeZ y))Future)Mapping)ManagedEventLoop)SinglePublisherAsyncSinglePublisherc leZdZUeed<eed<deffd Z d dedede eefdd fd Z d Z d Z xZ S)SinglePublisherImpl _managed_loop _underlying underlyingcPt|td|_||_y)NPublisherLoopThread)super__init__rr r )selfr __class__s Nlib/third_party/google/cloud/pubsublite/cloudpubsub/internal/publisher_impl.pyrzSinglePublisherImpl.__init__s$ -.CD%data ordering_keyattrsreturnz Future[str]c r|jj|jjd||d|S)N)rr)r submitr publish)rrrrs rrzSinglePublisherImpl.publish$s=!!(( $D   $ $ S$\ SU S  rc|jj|jj|jj j |SN)r __enter__rr __aenter__result)rs rrzSinglePublisherImpl.__enter__+sE $$& !!$"2"2"="="?@GGI rc|jj|jj|||j |jj |||yr)r rr __aexit__r!__exit__)r_SinglePublisherImpl__exc_type_SinglePublisherImpl__exc_value_SinglePublisherImpl__tracebacks rr$zSinglePublisherImpl.__exit__0sM !!    & &z; L &( ##J [Ir))__name__ __module__ __qualname__r__annotations__rrbytesstrrrrr$ __classcell__)rs@rr r sZ##%%& 02  ), r4s%& J/Jr