h,SrSSKrSSKJr SSKJrJrJr "SS\R5r "SS\R5r S r S r g) z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. N)defer)bananaflavorsjellyc<\rSrSrSrSrSrSrSrSr Sr S r g ) Publishablez6An object whose cached state persists across sessions.c0UR5 Xlg)N) republish publishedID)selfr s ]/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/spread/publish.py__init__Publishable.__init__s &c8[R"5Ulg)z=Set the timestamp to current and (TODO) update all observers.N)time timestampr s rr Publishable.republishsrc$URU5$) (internal))getStateToPublishForr perspectives rview_getStateToPublish"Publishable.view_getStateToPublishs((55rc"UR5$)z:Implement me to special-case your state for a perspective.)getStateToPublishrs rr Publishable.getStateToPublishFor#s%%''rc2[SUR-5e)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)NotImplementedError __class__rs rrPublishable.getStateToPublish's!";dnn"LMMrcU(a'URnUR5RnOSnSn[R"X5UR UUUR S.$)z6Get all necessary metadata to keep a clientside cache.None)remoter rservicer)perspectiveName getService serviceNamer ViewPointr r)r robserverpnamesnames rgetStateToCacheAndObserveFor(Publishable.getStateToCacheAndObserveFor+s^ //E**,88EEE'' :++    r)r rN) __name__ __module__ __qualname____firstlineno____doc__rr rrrr0__static_attributes__rrrrs$@'%6(N rrcH\rSrSrSrSrSrS SjrSrSr Sr Sr S r S r g ) RemotePublished=z6The local representation of remote Publishable object.rcxSRURUR[UR5U5$)Nz {}-{}-{}.{})formatr(rstrr )r exts r getFileNameRemotePublished.getFileNameCs6## LL      !    rc8URRU5 /Ul[UR 5S5nUR 5nSSS5 [ R"[R"W55nURUR:HnU(a#URWR5 SUl gURRS5R!UR5 g!,(df  N=f![a SnN~f=f)Nrbrr)__dict__update_activationListenersopenr@readrunjellyrdecoderOSError _cbGotUpdate_wasCleanWhenLoadedr' callRemote addCallbacks)r statedataFiledatanewselfrecents rsetCopyableState RemotePublished.setCopyableStateKs U#$&! 9d&&($/8}}0 mmFMM$$78G&&$..8F    g.. /'(D $ KK " "#6 7 D DTEVEV W0/ F s(D C9D 9 DD DDcXURR5nUS US US US US U$)Nbrokerr'luidrG isActivated)rEcopy)r others r __getstate__RemotePublished.__getstate__\s? ""$ (O (O &M ( ) -  rcURRU5 SUlURH nU"U5 M /UlUR 5 [ UR 5S5nUR[R"[R"U555 SSS5 g!,(df  g=f)NrDwb) rErFr[rG activatedrHr@writerencoder)r newStatelistenerrRs rrMRemotePublished._cbGotUpdategs X&11H TN2$&!  $""$d +x NN6==T):; <, + +s /:B22 Ccg)z^Implement this method if you want to be notified when your publishable subclass is activated. Nr8rs rrbRemotePublished.activatedrsrcnUR(a U"U5 gURRU5 g)zZExternally register for notification when this publishable has received all relevant data.N)r[rGappend)r callbacks rcallWhenActivated!RemotePublished.callWhenActivatedws&    TN  % % , ,X 6r)rGrNr[N)pub)r2r3r4r5r6r[rNr@rVr^rMrbrmr7r8rrr:r:=s/@K X"  = 7rr:cp[R"5nUR[URU4S9 U$)a, Wrap a deferred returned from a pb method in another deferred that expects a RemotePublished as a result. This will allow you to wait until the result is really available. Idiomatic usage would look like:: publish.whenReady(serverObject.getMeAPublishable()).addCallback(lookAtThePublishable) ) callbackArgs)rDeferredrP _pubReadyerrback)dd2s r whenReadyrws-  BNN9bjjuN= Irc:URUR5 g)rN)rmrl)resultrvs rrsrss R[[)r)r6rtwisted.internetrtwisted.spreadrrr Cacheabler RemoteCacher:rwrsr8rrr~sH  "11& '##& R?7g))?7D *r