Ñò c3Lc@sldZddkZddkZddkZddkTdeifd„ƒYZedjoeiƒndS(s'benoitc@e-engura.com (Benoît Chesneau)iÿÿÿÿN(t*tClientServerTestCasecBs5eZd„Zd„Zd„Zd„Zd„ZRS(cCs7tƒ|_|iidƒ|_t|iƒ|_dS(Ntcouchdbkit_test(tServertservert create_dbtdbtConsumertconsumer(tself((sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pytsetUps cCsy|id=WnnXdS(NR(R(R ((sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyttearDownscCsÖ|iiƒ}|id|jƒ|i|ddjƒ|i|dgjƒh}|ii|ƒ|iiƒ}|i|ddjƒ|it|dƒdjƒ|dd}|i|d|djƒdS(Ntlast_seqitresultsitidt_id(Rtfetchtassert_Rtsave_doctlen(R tres1tdoctres2tline((sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyt test_fetchscsd‡fd†}ˆii|ƒtidˆiiƒ}t|_|iƒh}ˆii |ƒdS(Ncs8ˆi|ddjƒˆit|dƒdjƒdS(NR iR (RR(R(R (sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyt test_line*sttarget( Rtregister_callbackt threadingtThreadt wait_oncetTruetdaemontstartRR(R RttR((R sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyt test_longpoll(s  csMgˆ_‡fd†}ˆii|ƒtidˆiiƒ}t|_|iƒx;t dƒD]-}hdt |ƒd6}ˆi i |ƒq`Wˆi i ƒtidƒˆitˆiƒdjƒˆiˆiddd jƒhd d6}ˆi i |ƒtidƒˆitˆiƒd jƒˆiˆiddd jƒdS( Ncsˆii|ƒdS(N(tlinestappend(R(R (sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyR7sRistest%sRgà?iRttest4ttest5i(R$RRRRtwaitRR R!trangetstrRRtensure_full_committtimetsleepRR(R RR"tiR((R sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyttest_continuous5s&        (t__name__t __module__R R RR#R/(((sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyRs    t__main__( t __author__RtunittestR,t couchdbkittTestCaseRR0tmain(((sH/Users/benoitc/Work/couchdbkit_env/src/couchdbkit/tests/test_consumer.pyts    >