SSKJr SSKrSSKJrJr SSKJr SSKJ r SSK J r "SS\5r \R"5r\R\ R 5 "S S \5rg) )futuresN) NamedTupleCallable)Message) PubsubMessage)AcknowledgeStatusc8\rSrSr%\\S'\\S'S\4SjrSrg)AckId generationoffsetreturnc^[UR5S-[UR5-$)N,)strr r selfs Olib/third_party/google/cloud/pubsublite/cloudpubsub/internal/wrapped_message.pyencode AckId.encodes$4??#c)C ,<<<N) __name__ __module__ __qualname____firstlineno__int__annotations__rr__static_attributes__rrrr r sO K==rr c^\rSrSr%\\S'\\\/S4\S'S\RRS\S\\\/S44U4Sjjr S r SS jr S rSSjrSrS\4SjrS\S S 4SjrSrU=r$)WrappedMessage_idN _ack_handlerpback_id ack_handlerc\>[TU]XR5SS5 X lX0lg)N)super__init__rr#r$)rr%r&r' __class__s rr+WrappedMessage.__init__s' ]]_a6'rc<URURS5 gNTr$r#rs rackWrappedMessage.ack$s $((D)rrfutures.FuturecFURURS5 [$r/r$r#_SUCCESS_FUTURErs rack_with_response WrappedMessage.ack_with_response's $((D)rc<URURS5 gNFr0rs rnackWrappedMessage.nack+s $((E*rcFURURS5 [$r:r5rs rnack_with_response!WrappedMessage.nack_with_response.s $((E*rc0[R"S5 g)NznLikely incorrect call to drop() on Pub/Sub Lite message. Pub/Sub Lite does not support redelivery in this way.loggingwarningrs rdropWrappedMessage.drop2s | rsecondsc0[R"S5 g)Nz}Likely incorrect call to modify_ack_deadline() on Pub/Sub Lite message. Pub/Sub Lite does not support redelivery in this way.rArrFs rmodify_ack_deadline"WrappedMessage.modify_ack_deadline7s L rc:[R"S5 [$)NzLikely incorrect call to modify_ack_deadline_with_response() on Pub/Sub Lite message. Pub/Sub Lite does not support redelivery in this way.)rBrCr6rHs r!modify_ack_deadline_with_response0WrappedMessage.modify_ack_deadline_with_response<s Z rr0)rr3)rrrrr rrboolrmetar%r+r1r7r;r>rDrrIrLr __classcell__)r,s@rr!r!s JE4=$.//(    ! !((udmT12 (*+  3 AQrr!) concurrentrrBtypingrr)google.cloud.pubsub_v1.subscriber.messagergoogle.pubsub_v1r,google.cloud.pubsub_v1.subscriber.exceptionsrr Futurer6 set_resultSUCCESSr!rrrrYsR'=*J=J=..",445*W*r