+ j,Rt^RIt^RIHt^RIHtHtHt!RR]P4t !RR]P4t Rt R t R#) z] Persistently cached objects for PB. Maintainer: Glyph Lefkowitz Future Plans: None known. N)defer)bananaflavorsjellycHa]tRt^toRtRtRtRtRtRt Rt Rt Vt R #) Publishablez6An object whose cached state persists across sessions.c2VP4WnR#)N) republish publishedID)selfr s&&8/usr/lib/python3/dist-packages/twisted/spread/publish.py__init__Publishable.__init__s &c :\P!4VnR#)z=Set the timestamp to current and (TODO) update all observers.N)time timestampr s&r r Publishable.republishsrc $VPV4#) (internal))getStateToPublishForr perspectives&&r view_getStateToPublish"Publishable.view_getStateToPublishs((55rc "VP4#)z:Implement me to special-case your state for a perspective.)getStateToPublishrs&&r r Publishable.getStateToPublishFor#s%%''rc :\RVP,4h)zBImplement me to return state to copy as part of the publish phase.z%s.getStateToPublishFor)NotImplementedError __class__rs&r rPublishable.getStateToPublish's!";dnn"LMMrc  V'd(VPpVP4PpMRpRpR\P!W4RVP RVRVRVP /#)z6Get all necessary metadata to keep a clientside cache.Noneremoter rservicer)perspectiveName getService serviceNamer ViewPointr r)r robserverpnamesnames&&& r getStateToCacheAndObserveFor(Publishable.getStateToCacheAndObserveFor+sh //E**,88EEE g'' : 4++ 5 u    r)r rN) __name__ __module__ __qualname____firstlineno____doc__r r rrrr.__static_attributes____classdictcell__ __classdict__s@r rrs,@'%6(N  rrcTa]tRt^=toRt^t^tR RltRtRt Rt Rt Rt Rt VtR #) RemotePublishedz6The local representation of remote Publishable object.cxRPVPVP\VP4V4#)z {}-{}-{}.{})formatr&rstrr )r exts&&r getFileNameRemotePublished.getFileNameCs6## LL      !    rcTVPPV4.Vn\VP 4R4;_uu_4pVP 4pRRR4\ P!\P!X44pVPVP8HpV'd%VPXP4^Vn R#VPPR4P!VP4R# +'giL;i \d^pLi;i)rbNr)__dict__update_activationListenersopenr?readrunjellyrdecoderOSError _cbGotUpdate_wasCleanWhenLoadedr% callRemote addCallbacks)r statedataFiledatanewselfrecents&& r setCopyableState RemotePublished.setCopyableStateKs U#$&! 9d&&($//8}}0 mmFMM$$78G&&$..8F    g.. /'(D $ KK " "#6 7 D DTEVEV W0/ F s)"DDD D D D'&D'cXVPP4pVRVRVRVRVRV#)brokerr%luidrE isActivated)rCcopy)r others& r __getstate__RemotePublished.__getstate__\s? ""$ (O (O &M ( ) -  rc VPPV4^VnVPF pV!V4K .VnVP 4\ VP 4R4;_uu_4pVP\P!\P!V444RRR4R# +'giR#;i)wbN) rCrDrYrE activatedrFr?writerencoder)r newStatelistenerrPs&& r rKRemotePublished._cbGotUpdategs X&11H TN2$&!  $""$d + +x NN6==T):; <, + + +s 7:B;; C c R#)z^Implement this method if you want to be notified when your publishable subclass is activated. Nrs&r raRemotePublished.activatedrsrc tVP'd V!V4R#VPPV4R#)zZExternally register for notification when this publishable has received all relevant data.N)rYrEappend)r callbacks&&r callWhenActivated!RemotePublished.callWhenActivatedws)     TN  % % , ,X 6r)rErLrYN)pub)r0r1r2r3r4rYrLr?rTr\rKrarmr5r6r7s@r r:r:=s7@K X"  = 77rr:cv\P!4pVP\VPV3R7V#)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)rDeferredrN _pubReadyerrback)dd2s& r whenReadyrws-  BNN9bjjuN= Irc<VPVP4R#)rN)rmrl)resultrvs&&r rsrss R[[)r)r4rtwisted.internetrtwisted.spreadrrr Cacheabler RemoteCacher:rwrsrhrr r~sH  "11& '##& R?7g))?7D *r