123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596459745984599460046014602460346044605460646074608460946104611461246134614461546164617461846194620462146224623462446254626462746284629463046314632463346344635463646374638463946404641464246434644464546464647464846494650465146524653465446554656465746584659466046614662466346644665466646674668466946704671467246734674467546764677467846794680468146824683468446854686468746884689469046914692469346944695469646974698469947004701470247034704470547064707470847094710471147124713471447154716471747184719472047214722472347244725472647274728472947304731473247334734473547364737473847394740474147424743474447454746474747484749475047514752475347544755475647574758475947604761476247634764476547664767476847694770477147724773477447754776477747784779478047814782478347844785478647874788478947904791479247934794479547964797479847994800480148024803480448054806480748084809481048114812481348144815481648174818481948204821482248234824482548264827482848294830483148324833483448354836483748384839484048414842484348444845484648474848484948504851485248534854485548564857485848594860486148624863486448654866486748684869487048714872487348744875487648774878487948804881488248834884488548864887488848894890489148924893489448954896489748984899490049014902490349044905490649074908490949104911491249134914491549164917491849194920492149224923492449254926492749284929493049314932493349344935493649374938493949404941494249434944494549464947494849494950495149524953495449554956495749584959496049614962496349644965496649674968496949704971497249734974497549764977497849794980498149824983498449854986498749884989499049914992499349944995499649974998499950005001500250035004500550065007500850095010501150125013501450155016501750185019502050215022502350245025502650275028502950305031503250335034503550365037503850395040504150425043504450455046504750485049505050515052505350545055505650575058505950605061506250635064506550665067506850695070507150725073507450755076507750785079508050815082508350845085508650875088508950905091509250935094509550965097509850995100510151025103510451055106510751085109511051115112511351145115511651175118511951205121512251235124512551265127512851295130513151325133513451355136513751385139514051415142514351445145514651475148514951505151515251535154515551565157515851595160516151625163516451655166516751685169517051715172517351745175517651775178517951805181518251835184518551865187518851895190519151925193519451955196519751985199520052015202520352045205520652075208520952105211521252135214521552165217521852195220522152225223522452255226522752285229523052315232523352345235523652375238523952405241524252435244524552465247524852495250525152525253525452555256525752585259526052615262526352645265526652675268526952705271527252735274527552765277527852795280528152825283528452855286528752885289529052915292529352945295529652975298529953005301530253035304530553065307530853095310531153125313531453155316531753185319532053215322532353245325532653275328532953305331533253335334533553365337533853395340534153425343534453455346534753485349535053515352535353545355535653575358535953605361536253635364536553665367536853695370537153725373537453755376537753785379538053815382538353845385538653875388538953905391539253935394539553965397539853995400540154025403540454055406540754085409541054115412541354145415541654175418541954205421542254235424542554265427542854295430543154325433543454355436543754385439544054415442544354445445544654475448544954505451545254535454545554565457545854595460546154625463546454655466546754685469547054715472547354745475547654775478547954805481548254835484548554865487548854895490549154925493549454955496549754985499550055015502550355045505550655075508550955105511551255135514551555165517551855195520552155225523552455255526552755285529553055315532553355345535553655375538553955405541554255435544554555465547554855495550555155525553555455555556555755585559556055615562556355645565556655675568556955705571557255735574557555765577557855795580558155825583558455855586558755885589559055915592559355945595559655975598559956005601560256035604560556065607560856095610561156125613561456155616561756185619562056215622562356245625562656275628562956305631563256335634563556365637563856395640564156425643564456455646564756485649565056515652565356545655565656575658565956605661566256635664566556665667566856695670567156725673567456755676567756785679568056815682568356845685568656875688568956905691569256935694569556965697569856995700570157025703570457055706570757085709571057115712571357145715571657175718571957205721572257235724572557265727572857295730573157325733573457355736573757385739574057415742574357445745574657475748574957505751575257535754575557565757575857595760576157625763576457655766576757685769577057715772577357745775577657775778577957805781578257835784578557865787578857895790579157925793579457955796579757985799580058015802580358045805580658075808580958105811581258135814581558165817581858195820582158225823582458255826582758285829583058315832583358345835583658375838583958405841584258435844584558465847584858495850585158525853585458555856585758585859586058615862586358645865586658675868586958705871587258735874587558765877587858795880588158825883588458855886588758885889589058915892589358945895589658975898589959005901590259035904590559065907590859095910591159125913591459155916591759185919592059215922592359245925592659275928592959305931593259335934593559365937593859395940594159425943594459455946594759485949595059515952595359545955595659575958595959605961596259635964596559665967596859695970597159725973597459755976597759785979598059815982598359845985598659875988598959905991599259935994599559965997599859996000600160026003600460056006600760086009601060116012601360146015601660176018601960206021602260236024602560266027602860296030603160326033603460356036603760386039604060416042604360446045604660476048604960506051605260536054605560566057605860596060606160626063606460656066606760686069607060716072607360746075607660776078607960806081608260836084608560866087608860896090609160926093609460956096609760986099610061016102610361046105610661076108610961106111611261136114611561166117611861196120612161226123612461256126612761286129613061316132613361346135613661376138613961406141614261436144614561466147614861496150615161526153615461556156615761586159616061616162616361646165616661676168616961706171617261736174617561766177617861796180618161826183618461856186618761886189619061916192619361946195619661976198619962006201620262036204620562066207620862096210621162126213621462156216621762186219622062216222622362246225622662276228622962306231623262336234623562366237623862396240624162426243624462456246624762486249625062516252625362546255625662576258625962606261626262636264626562666267626862696270627162726273627462756276627762786279628062816282628362846285628662876288628962906291629262936294629562966297629862996300630163026303630463056306630763086309631063116312631363146315631663176318631963206321632263236324632563266327632863296330633163326333633463356336633763386339634063416342634363446345634663476348634963506351635263536354635563566357635863596360636163626363636463656366636763686369637063716372637363746375637663776378637963806381638263836384638563866387638863896390639163926393639463956396639763986399640064016402640364046405640664076408640964106411641264136414641564166417641864196420642164226423642464256426642764286429643064316432643364346435643664376438643964406441644264436444644564466447644864496450645164526453645464556456645764586459646064616462646364646465646664676468646964706471647264736474647564766477647864796480648164826483648464856486648764886489649064916492649364946495649664976498649965006501650265036504650565066507650865096510651165126513651465156516651765186519652065216522652365246525652665276528652965306531653265336534653565366537653865396540654165426543654465456546654765486549655065516552655365546555655665576558655965606561656265636564656565666567656865696570657165726573657465756576657765786579658065816582658365846585658665876588658965906591659265936594659565966597659865996600660166026603660466056606660766086609661066116612661366146615661666176618661966206621662266236624662566266627662866296630663166326633663466356636663766386639664066416642664366446645664666476648664966506651665266536654665566566657665866596660666166626663666466656666666766686669667066716672667366746675667666776678667966806681668266836684668566866687668866896690669166926693669466956696669766986699670067016702670367046705670667076708670967106711671267136714671567166717671867196720672167226723672467256726672767286729673067316732673367346735673667376738673967406741674267436744674567466747674867496750675167526753675467556756675767586759676067616762676367646765676667676768676967706771677267736774677567766777677867796780678167826783678467856786678767886789679067916792679367946795679667976798679968006801680268036804680568066807680868096810681168126813681468156816681768186819682068216822682368246825682668276828682968306831683268336834683568366837683868396840684168426843684468456846684768486849685068516852685368546855685668576858685968606861686268636864686568666867686868696870687168726873687468756876687768786879688068816882688368846885688668876888688968906891689268936894689568966897689868996900690169026903690469056906690769086909691069116912691369146915691669176918691969206921692269236924692569266927692869296930693169326933693469356936693769386939694069416942694369446945694669476948694969506951695269536954695569566957695869596960696169626963696469656966696769686969697069716972697369746975697669776978697969806981698269836984698569866987698869896990699169926993699469956996699769986999700070017002700370047005700670077008700970107011701270137014701570167017701870197020702170227023702470257026702770287029703070317032703370347035703670377038703970407041704270437044704570467047704870497050705170527053705470557056705770587059706070617062706370647065706670677068706970707071707270737074707570767077707870797080708170827083708470857086708770887089709070917092709370947095709670977098709971007101710271037104710571067107710871097110711171127113711471157116711771187119712071217122712371247125712671277128712971307131713271337134713571367137713871397140714171427143714471457146714771487149715071517152715371547155715671577158715971607161716271637164716571667167716871697170717171727173717471757176717771787179718071817182718371847185718671877188718971907191719271937194719571967197719871997200720172027203720472057206720772087209721072117212721372147215721672177218721972207221722272237224722572267227722872297230723172327233723472357236723772387239724072417242724372447245724672477248724972507251725272537254725572567257725872597260726172627263726472657266726772687269727072717272727372747275727672777278727972807281728272837284728572867287728872897290729172927293729472957296729772987299730073017302730373047305730673077308730973107311731273137314731573167317731873197320732173227323732473257326732773287329733073317332733373347335733673377338733973407341734273437344734573467347734873497350735173527353735473557356735773587359736073617362736373647365736673677368736973707371737273737374737573767377737873797380738173827383738473857386738773887389739073917392739373947395739673977398739974007401740274037404740574067407740874097410741174127413741474157416741774187419742074217422742374247425742674277428742974307431743274337434743574367437743874397440744174427443744474457446744774487449745074517452745374547455745674577458745974607461746274637464746574667467746874697470747174727473747474757476747774787479748074817482748374847485748674877488748974907491749274937494749574967497749874997500750175027503750475057506750775087509751075117512751375147515751675177518751975207521752275237524752575267527752875297530753175327533753475357536753775387539754075417542754375447545754675477548754975507551755275537554755575567557755875597560756175627563756475657566756775687569757075717572757375747575757675777578757975807581758275837584758575867587758875897590759175927593759475957596759775987599760076017602760376047605760676077608760976107611761276137614761576167617761876197620762176227623762476257626762776287629763076317632763376347635763676377638763976407641764276437644764576467647764876497650765176527653765476557656765776587659766076617662766376647665766676677668766976707671767276737674767576767677767876797680768176827683768476857686768776887689769076917692769376947695769676977698769977007701770277037704770577067707770877097710771177127713771477157716771777187719772077217722772377247725772677277728772977307731773277337734773577367737773877397740774177427743774477457746774777487749775077517752775377547755775677577758775977607761776277637764776577667767776877697770777177727773777477757776777777787779778077817782778377847785778677877788778977907791779277937794779577967797779877997800780178027803780478057806780778087809781078117812781378147815781678177818781978207821782278237824782578267827782878297830783178327833783478357836783778387839784078417842784378447845784678477848784978507851785278537854785578567857785878597860786178627863786478657866786778687869787078717872787378747875787678777878787978807881788278837884788578867887788878897890789178927893789478957896789778987899790079017902790379047905790679077908790979107911791279137914791579167917791879197920792179227923792479257926792779287929793079317932793379347935793679377938793979407941794279437944794579467947794879497950795179527953795479557956795779587959796079617962796379647965796679677968796979707971797279737974797579767977797879797980798179827983798479857986798779887989799079917992799379947995799679977998799980008001800280038004800580068007800880098010801180128013801480158016801780188019802080218022802380248025802680278028802980308031803280338034803580368037803880398040804180428043804480458046804780488049805080518052805380548055805680578058805980608061806280638064806580668067806880698070807180728073807480758076807780788079808080818082808380848085808680878088808980908091809280938094809580968097809880998100810181028103810481058106810781088109811081118112811381148115811681178118811981208121812281238124812581268127812881298130813181328133813481358136813781388139814081418142814381448145814681478148814981508151815281538154815581568157815881598160816181628163816481658166816781688169817081718172817381748175817681778178817981808181818281838184818581868187818881898190819181928193819481958196819781988199820082018202820382048205820682078208820982108211821282138214821582168217821882198220822182228223822482258226822782288229823082318232823382348235823682378238823982408241824282438244824582468247824882498250825182528253825482558256825782588259826082618262826382648265826682678268826982708271827282738274827582768277827882798280828182828283828482858286828782888289829082918292829382948295829682978298829983008301830283038304830583068307830883098310831183128313831483158316831783188319832083218322832383248325832683278328832983308331833283338334833583368337833883398340834183428343834483458346834783488349835083518352835383548355835683578358835983608361836283638364836583668367836883698370837183728373837483758376837783788379838083818382838383848385838683878388838983908391839283938394839583968397839883998400840184028403840484058406840784088409841084118412841384148415841684178418841984208421842284238424842584268427842884298430843184328433843484358436843784388439844084418442844384448445844684478448844984508451845284538454845584568457845884598460846184628463846484658466846784688469847084718472847384748475847684778478847984808481848284838484848584868487848884898490849184928493849484958496849784988499850085018502850385048505850685078508850985108511851285138514851585168517851885198520852185228523852485258526852785288529853085318532853385348535853685378538853985408541854285438544854585468547854885498550855185528553855485558556855785588559856085618562856385648565856685678568856985708571857285738574857585768577857885798580858185828583858485858586858785888589859085918592859385948595859685978598859986008601860286038604860586068607860886098610861186128613861486158616861786188619862086218622862386248625862686278628862986308631863286338634863586368637863886398640864186428643864486458646864786488649865086518652865386548655865686578658865986608661866286638664866586668667866886698670867186728673867486758676867786788679868086818682868386848685868686878688868986908691869286938694869586968697869886998700870187028703870487058706870787088709871087118712871387148715871687178718871987208721872287238724872587268727872887298730873187328733873487358736873787388739874087418742874387448745874687478748874987508751875287538754875587568757875887598760876187628763876487658766876787688769877087718772877387748775877687778778877987808781878287838784878587868787878887898790879187928793879487958796879787988799880088018802880388048805880688078808880988108811881288138814881588168817881888198820882188228823882488258826882788288829883088318832883388348835883688378838883988408841884288438844884588468847884888498850885188528853885488558856885788588859886088618862886388648865886688678868886988708871887288738874887588768877887888798880888188828883888488858886888788888889889088918892889388948895889688978898889989008901890289038904890589068907890889098910891189128913891489158916891789188919892089218922892389248925892689278928892989308931893289338934893589368937893889398940894189428943894489458946894789488949895089518952895389548955895689578958895989608961896289638964896589668967896889698970897189728973897489758976897789788979898089818982898389848985898689878988898989908991899289938994899589968997899889999000900190029003900490059006900790089009901090119012 |
- // Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Reactive;
- using System.Reactive.Concurrency;
- using System.Reactive.Disposables;
- using System.Reactive.Linq;
- using System.Reactive.Subjects;
- using System.Text;
- using System.Threading;
- using Microsoft.Reactive.Testing;
- using Xunit;
- using ReactiveTests.Dummies;
- using System.Threading.Tasks;
- namespace ReactiveTests.Tests
- {
-
- public class ObservableTimeTest : ReactiveTest
- {
- #region + Buffer +
- [Fact]
- public void Buffer_Time_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(someObservable, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.Zero, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.Zero, TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(someObservable, TimeSpan.Zero, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.Zero, TimeSpan.Zero, scheduler));
- }
- [Fact]
- public void BufferWithTime_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.FromTicks(1), TimeSpan.FromTicks(1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), TimeSpan.FromTicks(1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), TimeSpan.FromTicks(-1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), TimeSpan.FromTicks(1), null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.FromTicks(1), TimeSpan.FromTicks(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), TimeSpan.FromTicks(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), TimeSpan.FromTicks(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.FromTicks(1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.FromTicks(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1)));
- }
- [Fact]
- public void BufferWithTime_Basic1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(70), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(300, "2,3,4"),
- OnNext(370, "4,5,6"),
- OnNext(440, "6,7,8"),
- OnNext(510, "8,9"),
- OnNext(580, ""),
- OnNext(600, ""),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void BufferWithTime_Basic2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(70), TimeSpan.FromTicks(100), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(270, "2,3"),
- OnNext(370, "5,6"),
- OnNext(470, "8,9"),
- OnNext(570, ""),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void BufferWithTime_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnError<int>(600, ex)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(70), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(300, "2,3,4"),
- OnNext(370, "4,5,6"),
- OnNext(440, "6,7,8"),
- OnNext(510, "8,9"),
- OnNext(580, ""),
- OnError<string>(600, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void BufferWithTime_Disposed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(70), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray())),
- 370
- );
- res.Messages.AssertEqual(
- OnNext(300, "2,3,4")
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 370)
- );
- }
- [Fact]
- public void BufferWithTime_Basic_Same()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(100), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(300, "2,3,4"),
- OnNext(400, "5,6,7"),
- OnNext(500, "8,9"),
- OnNext(600, ""),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void BufferWithTime_Basic_Same_Periodic()
- {
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(100), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(300, "2,3,4"),
- OnNext(400, "5,6,7"),
- OnNext(500, "8,9"),
- OnNext(600, ""),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 600) { 300, 400, 500 }
- );
- #endif
- }
- [Fact]
- public void BufferWithTime_Basic_Same_Periodic_Error()
- {
- var ex = new Exception();
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnError<int>(480, ex)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(100), scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(300, "2,3,4"),
- OnNext(400, "5,6,7"),
- OnError<string>(480, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 480)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 480) { 300, 400 }
- );
- #endif
- }
- [Fact]
- public void BufferWithTime_Default()
- {
- Observable.Range(0, 10).Buffer(TimeSpan.FromDays(1), TimeSpan.FromDays(1)).First().AssertEqual(Enumerable.Range(0, 10));
- Observable.Range(0, 10).Buffer(TimeSpan.FromDays(1)).First().AssertEqual(Enumerable.Range(0, 10));
- }
- [Fact]
- public void BufferWithTimeOrCount_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.FromTicks(1), 1, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), 1, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), 0, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), 1, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Buffer(default(IObservable<int>), TimeSpan.FromTicks(1), 1));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), 1));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Buffer(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), 0));
- }
- [Fact]
- public void BufferWithTimeOrCount_Basic()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(205, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(370, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(70), 3, scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(240, "1,2,3"),
- OnNext(310, "4"),
- OnNext(370, "5,6,7"),
- OnNext(440, "8"),
- OnNext(510, "9"),
- OnNext(580, ""),
- OnNext(600, ""),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void BufferWithTimeOrCount_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(205, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(370, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnError<int>(600, ex)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(70), 3, scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray()))
- );
- res.Messages.AssertEqual(
- OnNext(240, "1,2,3"),
- OnNext(310, "4"),
- OnNext(370, "5,6,7"),
- OnNext(440, "8"),
- OnNext(510, "9"),
- OnNext(580, ""),
- OnError<string>(600, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void BufferWithTimeOrCount_Disposed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(205, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(370, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Buffer(TimeSpan.FromTicks(70), 3, scheduler).Select(x => string.Join(",", x.Select(xx => xx.ToString()).ToArray())),
- 370
- );
- res.Messages.AssertEqual(
- OnNext(240, "1,2,3"),
- OnNext(310, "4"),
- OnNext(370, "5,6,7")
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 370)
- );
- }
- [Fact]
- public void BufferWithTimeOrCount_Default()
- {
- Observable.Range(1, 10, DefaultScheduler.Instance).Buffer(TimeSpan.FromDays(1), 3).Skip(1).First().AssertEqual(4, 5, 6);
- }
- #endregion
- #region + Delay +
- [Fact]
- public void Delay_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(default(IObservable<int>), DateTimeOffset.Now));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(default(IObservable<int>), TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Delay(someObservable, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(default(IObservable<int>), DateTimeOffset.Now, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(default(IObservable<int>), TimeSpan.Zero, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(someObservable, DateTimeOffset.Now, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(someObservable, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Delay(someObservable, TimeSpan.FromSeconds(-1), scheduler));
- }
- [Fact]
- public void Delay_TimeSpan_Simple1()
- {
- Delay_TimeSpan_Simple1_Impl(false);
- }
- [Fact]
- public void Delay_TimeSpan_Simple1_Stopwatch()
- {
- Delay_TimeSpan_Simple1_Impl(true);
- }
- private void Delay_TimeSpan_Simple1_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(100), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(350, 2),
- OnNext(450, 3),
- OnNext(550, 4),
- OnCompleted<int>(650)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_DateTimeOffset_Simple1()
- {
- Delay_DateTimeOffset_Simple1_Impl(false);
- }
- [Fact]
- public void Delay_DateTimeOffset_Simple1_Stopwatch()
- {
- Delay_DateTimeOffset_Simple1_Impl(true);
- }
- private void Delay_DateTimeOffset_Simple1_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(new DateTimeOffset(300, TimeSpan.Zero), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(350, 2),
- OnNext(450, 3),
- OnNext(550, 4),
- OnCompleted<int>(650)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_TimeSpan_Simple2()
- {
- Delay_TimeSpan_Simple2_Impl(false);
- }
- [Fact]
- public void Delay_TimeSpan_Simple2_Stopwatch()
- {
- Delay_TimeSpan_Simple2_Impl(true);
- }
- private void Delay_TimeSpan_Simple2_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(50), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(300, 2),
- OnNext(400, 3),
- OnNext(500, 4),
- OnCompleted<int>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_DateTimeOffset_Simple2()
- {
- Delay_DateTimeOffset_Simple2_Impl(false);
- }
- [Fact]
- public void Delay_DateTimeOffset_Simple2_Stopwatch()
- {
- Delay_DateTimeOffset_Simple2_Impl(true);
- }
- private void Delay_DateTimeOffset_Simple2_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(new DateTimeOffset(250, TimeSpan.Zero), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(300, 2),
- OnNext(400, 3),
- OnNext(500, 4),
- OnCompleted<int>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_TimeSpan_Simple3()
- {
- Delay_TimeSpan_Simple3_Impl(false);
- }
- [Fact]
- public void Delay_TimeSpan_Simple3_Stopwatch()
- {
- Delay_TimeSpan_Simple3_Impl(true);
- }
- private void Delay_TimeSpan_Simple3_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(150), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(400, 2),
- OnNext(500, 3),
- OnNext(600, 4),
- OnCompleted<int>(700)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_DateTimeOffset_Simple3()
- {
- Delay_DateTimeOffset_Simple3_Impl(false);
- }
- [Fact]
- public void Delay_DateTimeOffset_Simple3_Stopwatch()
- {
- Delay_DateTimeOffset_Simple3_Impl(true);
- }
- private void Delay_DateTimeOffset_Simple3_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(new DateTimeOffset(350, TimeSpan.Zero), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(400, 2),
- OnNext(500, 3),
- OnNext(600, 4),
- OnCompleted<int>(700)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_TimeSpan_Error1()
- {
- Delay_TimeSpan_Error1_Impl(false);
- }
- [Fact]
- public void Delay_TimeSpan_Error1_Stopwatch()
- {
- Delay_TimeSpan_Error1_Impl(true);
- }
- private void Delay_TimeSpan_Error1_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnError<int>(550, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(50), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(300, 2),
- OnNext(400, 3),
- OnNext(500, 4),
- OnError<int>(550, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_DateTimeOffset_Error1()
- {
- Delay_DateTimeOffset_Error1_Impl(false);
- }
- [Fact]
- public void Delay_DateTimeOffset_Error1_Stopwatch()
- {
- Delay_DateTimeOffset_Error1_Impl(true);
- }
- private void Delay_DateTimeOffset_Error1_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnError<int>(550, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(new DateTimeOffset(250, TimeSpan.Zero), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(300, 2),
- OnNext(400, 3),
- OnNext(500, 4),
- OnError<int>(550, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_TimeSpan_Error2()
- {
- Delay_TimeSpan_Error2_Impl(false);
- }
- [Fact]
- public void Delay_TimeSpan_Error2_Stopwatch()
- {
- Delay_TimeSpan_Error2_Impl(true);
- }
- private void Delay_TimeSpan_Error2_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnError<int>(550, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(150), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(400, 2),
- OnNext(500, 3),
- OnError<int>(550, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_DateTimeOffset_Error2()
- {
- Delay_DateTimeOffset_Error2_Impl(false);
- }
- [Fact]
- public void Delay_DateTimeOffset_Error2_Stopwatch()
- {
- Delay_DateTimeOffset_Error2_Impl(true);
- }
- private void Delay_DateTimeOffset_Error2_Impl(bool useStopwatch)
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnError<int>(550, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(new DateTimeOffset(350, TimeSpan.Zero), useStopwatch ? scheduler : scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(400, 2),
- OnNext(500, 3),
- OnError<int>(550, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- #if !NO_THREAD
- [Fact]
- public void Delay_TimeSpan_Real_Simple1()
- {
- Delay_TimeSpan_Real_Simple1_Impl(ThreadPoolScheduler.Instance.DisableOptimizations());
- }
- [Fact]
- public void Delay_TimeSpan_Real_Simple1_Stopwatch()
- {
- Delay_TimeSpan_Real_Simple1_Impl(ThreadPoolScheduler.Instance);
- }
- #endif
- private void Delay_TimeSpan_Real_Simple1_Impl(IScheduler scheduler)
- {
- var s = new Subject<int>();
- var res = s.Delay(TimeSpan.FromMilliseconds(10), scheduler);
- var lst = new List<int>();
- var e = new ManualResetEvent(false);
- res.Subscribe(lst.Add, () => e.Set());
- Task.Run(() =>
- {
- s.OnNext(1);
- s.OnNext(2);
- s.OnNext(3);
- s.OnCompleted();
- });
- e.WaitOne();
- Assert.True(new[] { 1, 2, 3 }.SequenceEqual(lst));
- }
- #if !NO_THREAD
- [Fact]
- public void Delay_TimeSpan_Real_Error1()
- {
- Delay_TimeSpan_Real_Error1_Impl(ThreadPoolScheduler.Instance.DisableOptimizations());
- }
- [Fact]
- public void Delay_TimeSpan_Real_Error1_Stopwatch()
- {
- Delay_TimeSpan_Real_Error1_Impl(ThreadPoolScheduler.Instance);
- }
- #endif
- private void Delay_TimeSpan_Real_Error1_Impl(IScheduler scheduler)
- {
- var ex = new Exception();
- var s = new Subject<int>();
- var res = s.Delay(TimeSpan.FromMilliseconds(10), scheduler);
- var e = new ManualResetEvent(false);
- var err = default(Exception);
- res.Subscribe(_ => { }, ex_ => { err = ex_; e.Set(); });
- Task.Run(() =>
- {
- s.OnNext(1);
- s.OnNext(2);
- s.OnNext(3);
- s.OnError(ex);
- });
- e.WaitOne();
- Assert.Same(ex, err);
- }
- #if !NO_THREAD
- [Fact]
- public void Delay_TimeSpan_Real_Error2()
- {
- Delay_TimeSpan_Real_Error2_Impl(ThreadPoolScheduler.Instance.DisableOptimizations());
- }
- [Fact]
- public void Delay_TimeSpan_Real_Error2_Stopwatch()
- {
- Delay_TimeSpan_Real_Error2_Impl(ThreadPoolScheduler.Instance);
- }
- #endif
- private void Delay_TimeSpan_Real_Error2_Impl(IScheduler scheduler)
- {
- var ex = new Exception();
- var s = new Subject<int>();
- var res = s.Delay(TimeSpan.FromMilliseconds(10), scheduler);
- var next = new ManualResetEvent(false);
- var e = new ManualResetEvent(false);
- var err = default(Exception);
- res.Subscribe(_ => { next.Set(); }, ex_ => { err = ex_; e.Set(); });
- Task.Run(() =>
- {
- s.OnNext(1);
- next.WaitOne();
- s.OnError(ex);
- });
- e.WaitOne();
- Assert.Same(ex, err);
- }
- #if !NO_THREAD
- [Fact]
- public void Delay_TimeSpan_Real_Error3()
- {
- Delay_TimeSpan_Real_Error3_Impl(ThreadPoolScheduler.Instance.DisableOptimizations());
- }
- [Fact]
- public void Delay_TimeSpan_Real_Error3_Stopwatch()
- {
- Delay_TimeSpan_Real_Error3_Impl(ThreadPoolScheduler.Instance);
- }
- #endif
- private void Delay_TimeSpan_Real_Error3_Impl(IScheduler scheduler)
- {
- var ex = new Exception();
- var s = new Subject<int>();
- var res = s.Delay(TimeSpan.FromMilliseconds(10), scheduler);
- var next = new ManualResetEvent(false);
- var ack = new ManualResetEvent(false);
- var e = new ManualResetEvent(false);
- var err = default(Exception);
- res.Subscribe(_ => { next.Set(); ack.WaitOne(); }, ex_ => { err = ex_; e.Set(); });
- Task.Run(() =>
- {
- s.OnNext(1);
- next.WaitOne();
- s.OnError(ex);
- ack.Set();
- });
- e.WaitOne();
- Assert.Same(ex, err);
- }
- [Fact]
- public void Delay_TimeSpan_Positive()
- {
- var scheduler = new TestScheduler();
- var msgs = new[] {
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- };
- var xs = scheduler.CreateHotObservable(msgs);
- const ushort delay = 42;
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(delay), scheduler)
- );
- var expected = from n in msgs
- where n.Time > ObservableTest.Subscribed
- select new Recorded<Notification<int>>((ushort)(n.Time + delay), n.Value);
- res.Messages.AssertEqual(expected);
- }
- [Fact]
- public void Delay_Empty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(10), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(560)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnError<int>(550, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(10), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(550, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1)
- );
- var res = scheduler.Start(() =>
- xs.Delay(TimeSpan.FromTicks(10), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void Delay_TimeSpan_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Delay(TimeSpan.FromMilliseconds(1)).ToEnumerable().SequenceEqual(new[] { 1 }));
- }
- [Fact]
- public void Delay_DateTimeOffset_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Delay(DateTimeOffset.UtcNow + TimeSpan.FromMilliseconds(1)).ToEnumerable().SequenceEqual(new[] { 1 }));
- }
- [Fact]
- public void Delay_CrossingMessages()
- {
- var lst = new List<int>();
- var evt = new ManualResetEvent(false);
- var s = new Subject<int>();
- s.Delay(TimeSpan.FromSeconds(0.01)).Subscribe(x =>
- {
- lst.Add(x);
- if (x < 9)
- s.OnNext(x + 1);
- else
- s.OnCompleted();
- }, () =>
- {
- evt.Set();
- });
- s.OnNext(0);
- evt.WaitOne();
- Assert.True(Enumerable.Range(0, 10).SequenceEqual(lst));
- }
- [Fact]
- public void Delay_Duration_ArgumentChecking()
- {
- var someObservable = DummyObservable<int>.Instance;
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(default(IObservable<int>), x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(someObservable, default(Func<int, IObservable<int>>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(default(IObservable<int>), someObservable, x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(someObservable, default(IObservable<int>), x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Delay(someObservable, someObservable, default(Func<int, IObservable<int>>)));
- }
- [Fact]
- public void Delay_Duration_Simple1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 10),
- OnNext(220, 30),
- OnNext(230, 50),
- OnNext(240, 35),
- OnNext(250, 20),
- OnCompleted<int>(260)
- );
- var res = scheduler.Start(() =>
- xs.Delay(x => scheduler.CreateColdObservable(new[] { OnNext(x, "!") }))
- );
- res.Messages.AssertEqual(
- OnNext(210 + 10, 10),
- OnNext(220 + 30, 30),
- OnNext(250 + 20, 20),
- OnNext(240 + 35, 35),
- OnNext(230 + 50, 50),
- OnCompleted<int>(280)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 260)
- );
- }
- [Fact]
- public void Delay_Duration_Simple2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(10, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys)
- );
- res.Messages.AssertEqual(
- OnNext(210 + 10, 2),
- OnNext(220 + 10, 3),
- OnNext(230 + 10, 4),
- OnNext(240 + 10, 5),
- OnNext(250 + 10, 6),
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 220),
- Subscribe(220, 230),
- Subscribe(230, 240),
- Subscribe(240, 250),
- Subscribe(250, 260)
- );
- }
- [Fact]
- public void Delay_Duration_Simple3()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys)
- );
- res.Messages.AssertEqual(
- OnNext(210 + 100, 2),
- OnNext(220 + 100, 3),
- OnNext(230 + 100, 4),
- OnNext(240 + 100, 5),
- OnNext(250 + 100, 6),
- OnCompleted<int>(350)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 310),
- Subscribe(220, 320),
- Subscribe(230, 330),
- Subscribe(240, 340),
- Subscribe(250, 350)
- );
- }
- [Fact]
- public void Delay_Duration_Simple4_InnerEmpty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateColdObservable(
- OnCompleted<int>(100)
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys)
- );
- res.Messages.AssertEqual(
- OnNext(210 + 100, 2),
- OnNext(220 + 100, 3),
- OnNext(230 + 100, 4),
- OnNext(240 + 100, 5),
- OnNext(250 + 100, 6),
- OnCompleted<int>(350)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 310),
- Subscribe(220, 320),
- Subscribe(230, 330),
- Subscribe(240, 340),
- Subscribe(250, 350)
- );
- }
- [Fact]
- public void Delay_Duration_Dispose1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(200, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys),
- 425
- );
- res.Messages.AssertEqual(
- OnNext(210 + 200, 2),
- OnNext(220 + 200, 3)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 410),
- Subscribe(220, 420),
- Subscribe(230, 425),
- Subscribe(240, 425),
- Subscribe(250, 425)
- );
- }
- [Fact]
- public void Delay_Duration_Dispose2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(400, 3),
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(50, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys),
- 300
- );
- res.Messages.AssertEqual(
- OnNext(210 + 50, 2)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 260)
- );
- }
- [Fact]
- public void Delay_Duration_OuterError1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnError<int>(300, ex)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys)
- );
- res.Messages.AssertEqual(
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 300),
- Subscribe(220, 300),
- Subscribe(230, 300),
- Subscribe(240, 300),
- Subscribe(250, 300)
- );
- }
- [Fact]
- public void Delay_Duration_OuterError2()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnError<int>(300, ex)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(10, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys)
- );
- res.Messages.AssertEqual(
- OnNext(210 + 10, 2),
- OnNext(220 + 10, 3),
- OnNext(230 + 10, 4),
- OnNext(240 + 10, 5),
- OnNext(250 + 10, 6),
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 220),
- Subscribe(220, 230),
- Subscribe(230, 240),
- Subscribe(240, 250),
- Subscribe(250, 260)
- );
- }
- [Fact]
- public void Delay_Duration_InnerError1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(30, "!")
- );
- var zs = scheduler.CreateColdObservable(
- OnError<string>(25, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(x => x != 5 ? ys : zs)
- );
- res.Messages.AssertEqual(
- OnNext(210 + 30, 2),
- OnNext(220 + 30, 3),
- OnNext(230 + 30, 4),
- OnError<int>(240 + 25, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 265)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 240),
- Subscribe(220, 250),
- Subscribe(230, 260),
- Subscribe(250, 265)
- );
- }
- [Fact]
- public void Delay_Duration_InnerError2()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(220, 3),
- OnNext(230, 4),
- OnNext(240, 5),
- OnNext(250, 6),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateColdObservable(
- OnError<string>(100, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(_ => ys)
- );
- res.Messages.AssertEqual(
- OnError<int>(210 + 100, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(210, 310),
- Subscribe(220, 310),
- Subscribe(230, 310),
- Subscribe(240, 310),
- Subscribe(250, 310)
- );
- }
- [Fact]
- public void Delay_Duration_SelectorThrows1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(300, 3),
- OnNext(350, 4),
- OnNext(400, 5),
- OnNext(450, 6),
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext<string>(80, "")
- );
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- {
- if (x == 4)
- throw ex;
- return ys;
- })
- );
- res.Messages.AssertEqual(
- OnNext(330, 2),
- OnError<int>(350, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 350)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(250, 330),
- Subscribe(300, 350)
- );
- }
- [Fact]
- public void Delay_Duration_Simple()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnNext<int>(450 + 4 * 10, 4),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_Duration_DeferOnCompleted()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(451)
- );
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnNext<int>(450 + 4 * 10, 4),
- OnCompleted<int>(450 + 4 * 10)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 451)
- );
- }
- [Fact]
- public void Delay_Duration_InnerError()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(451)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- x < 4 ? scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- )
- : scheduler.CreateColdObservable(
- OnError<string>(x * 10, ex)
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnError<int>(450 + 4 * 10, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 451)
- );
- }
- [Fact]
- public void Delay_Duration_OuterError()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnError<int>(460, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnError<int>(460, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 460)
- );
- }
- [Fact]
- public void Delay_Duration_SelectorThrows2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- {
- if (x < 4)
- {
- return scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- );
- }
- else
- throw ex;
- })
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnError<int>(450, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 450)
- );
- }
- [Fact]
- public void Delay_Duration_InnerDone()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Delay(x =>
- scheduler.CreateColdObservable(
- OnCompleted<string>(x * 10)
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnNext<int>(450 + 4 * 10, 4),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Delay_Duration_InnerSubscriptionTimes()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, -1),
- OnNext(250, 0),
- OnNext(350, 1),
- OnNext(450, 2),
- OnCompleted<int>(550)
- );
- var ys = new[] {
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(10, 43),
- OnNext(15, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(30, 44),
- OnNext(35, 99)
- ),
- };
- var res = scheduler.Start(() =>
- xs.Delay(x => ys[x])
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 20, 0),
- OnNext<int>(350 + 10, 1),
- OnNext<int>(450 + 30, 2),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- ys[0].Subscriptions.AssertEqual(Subscribe(250, 250 + 20));
- ys[1].Subscriptions.AssertEqual(Subscribe(350, 350 + 10));
- ys[2].Subscriptions.AssertEqual(Subscribe(450, 450 + 30));
- }
- [Fact]
- public void Delay_DurationAndSubscription_Simple1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 10),
- OnNext(220, 30),
- OnNext(230, 50),
- OnNext(240, 35),
- OnNext(250, 20),
- OnCompleted<int>(260)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(10, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(ys, x => scheduler.CreateColdObservable(new[] { OnNext(x, "!") }))
- );
- res.Messages.AssertEqual(
- OnNext(220 + 30, 30),
- OnNext(250 + 20, 20),
- OnNext(240 + 35, 35),
- OnNext(230 + 50, 50),
- OnCompleted<int>(280)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(210, 260)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void Delay_DurationAndSubscription_Simple2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 10),
- OnNext(220, 30),
- OnNext(230, 50),
- OnNext(240, 35),
- OnNext(250, 20),
- OnCompleted<int>(260)
- );
- var ys = scheduler.CreateColdObservable(
- OnCompleted<string>(10)
- );
- var res = scheduler.Start(() =>
- xs.Delay(ys, x => scheduler.CreateColdObservable(new[] { OnNext(x, "!") }))
- );
- res.Messages.AssertEqual(
- OnNext(220 + 30, 30),
- OnNext(250 + 20, 20),
- OnNext(240 + 35, 35),
- OnNext(230 + 50, 50),
- OnCompleted<int>(280)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(210, 260)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void Delay_DurationAndSubscription_Dispose1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 10),
- OnNext(220, 30),
- OnNext(230, 50),
- OnNext(240, 35),
- OnNext(250, 20),
- OnCompleted<int>(260)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext<string>(10, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(ys, x => scheduler.CreateColdObservable(new[] { OnNext(x, "!") })),
- 255
- );
- res.Messages.AssertEqual(
- OnNext(220 + 30, 30)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(210, 255)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void Delay_DurationAndSubscription_Dispose2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 10),
- OnNext(220, 30),
- OnNext(230, 50),
- OnNext(240, 35),
- OnNext(250, 20),
- OnCompleted<int>(260)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext<string>(100, "!")
- );
- var res = scheduler.Start(() =>
- xs.Delay(ys, x => scheduler.CreateColdObservable(new[] { OnNext(x, "!") })),
- 255
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 255)
- );
- }
- [Fact]
- public void Delay_DurationAndSubscription_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 10),
- OnNext(220, 30),
- OnNext(230, 50),
- OnNext(240, 35),
- OnNext(250, 20),
- OnCompleted<int>(260)
- );
- var ys = scheduler.CreateColdObservable(
- OnError<string>(10, ex)
- );
- var res = scheduler.Start(() =>
- xs.Delay(ys, x => scheduler.CreateColdObservable(new[] { OnNext(x, "!") }))
- );
- res.Messages.AssertEqual(
- OnError<int>(200 + 10, ex)
- );
- xs.Subscriptions.AssertEqual(
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void Delay_ErrorHandling1()
- {
- //
- // Checks for race condition between OnNext and OnError where the latter has a chance to
- // send out the OnError message before the former gets a chance to run in the delayed
- // queue. In that case, the OnNext message should not come out.
- //
- // See DrainQueue's first _hasFailed check.
- //
- var xs = Observable.Create<int>(observer =>
- {
- observer.OnNext(42);
- observer.OnError(new Exception());
- return () => { };
- });
- var s = new ImpulseScheduler();
- var called = false;
- var failed = new ManualResetEvent(false);
- xs.Delay(TimeSpan.FromDays(1), s).Subscribe(_ => { called = true; }, ex => { failed.Set(); });
- failed.WaitOne();
- s.Event.Set();
- s.Done.WaitOne();
- Assert.False(called);
- }
- class ImpulseScheduler : IScheduler
- {
- public DateTimeOffset Now
- {
- get { return DateTimeOffset.UtcNow; }
- }
- public IDisposable Schedule<TState>(TState state, Func<IScheduler, TState, IDisposable> action)
- {
- throw new NotImplementedException();
- }
- private ManualResetEvent _event = new ManualResetEvent(false);
- private ManualResetEvent _done = new ManualResetEvent(false);
- public ManualResetEvent Event { get { return _event; } }
- public ManualResetEvent Done { get { return _done; } }
- public IDisposable Schedule<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action)
- {
- Scheduler.Default.Schedule(() =>
- {
- _event.WaitOne();
- action(this, state);
- _done.Set();
- });
- return Disposable.Empty;
- }
- public IDisposable Schedule<TState>(TState state, DateTimeOffset dueTime, Func<IScheduler, TState, IDisposable> action)
- {
- throw new NotImplementedException();
- }
- }
- [Fact]
- public void Delay_LongRunning_CancelEarly()
- {
- var xs = Observable.Create<int>(observer =>
- {
- return Scheduler.Default.Schedule(TimeSpan.FromHours(1), () =>
- {
- observer.OnNext(42);
- });
- });
- var s = new ManualResetEvent(false);
- var e = new ManualResetEvent(false);
- var ys = xs.Delay(TimeSpan.Zero, new MyLongRunning1(s, e));
- var d = ys.Subscribe(_ => { });
- s.WaitOne();
- d.Dispose();
- e.WaitOne();
- }
- class MyLongRunning1 : LocalScheduler, ISchedulerLongRunning
- {
- private ManualResetEvent _start;
- private ManualResetEvent _stop;
- public MyLongRunning1(ManualResetEvent start, ManualResetEvent stop)
- {
- _start = start;
- _stop = stop;
- }
- public IDisposable ScheduleLongRunning<TState>(TState state, Action<TState, ICancelable> action)
- {
- var b = new BooleanDisposable();
- Task.Run(() =>
- {
- _start.Set();
- action(state, b);
- _stop.Set();
- });
- return b;
- }
- public override IDisposable Schedule<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action)
- {
- throw new NotImplementedException();
- }
- }
- [Fact]
- public void Delay_LongRunning_CancelLate()
- {
- var xs = Observable.Return(42);
- var s = new ManualResetEvent(false);
- var e = new ManualResetEvent(false);
- var ys = xs.Delay(TimeSpan.FromHours(1), new MyLongRunning2(s, e));
- var d = ys.Subscribe(_ => { });
- s.WaitOne();
- d.Dispose();
- e.WaitOne();
- }
- class MyLongRunning2 : LocalScheduler, ISchedulerLongRunning
- {
- private ManualResetEvent _start;
- private ManualResetEvent _stop;
- public MyLongRunning2(ManualResetEvent start, ManualResetEvent stop)
- {
- _start = start;
- _stop = stop;
- }
- public IDisposable ScheduleLongRunning<TState>(TState state, Action<TState, ICancelable> action)
- {
- var b = new BooleanDisposable();
- Task.Run(() =>
- {
- action(state, b);
- _stop.Set();
- });
- return b;
- }
- public override IDisposable Schedule<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action)
- {
- _start.Set();
- return Disposable.Empty;
- }
- }
- #endregion
- #region + DelaySubscription +
- [Fact]
- public void DelaySubscription_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DelaySubscription(default(IObservable<int>), DateTimeOffset.Now));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DelaySubscription(default(IObservable<int>), DateTimeOffset.Now, Scheduler.Immediate));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DelaySubscription(DummyObservable<int>.Instance, DateTimeOffset.Now, default(IScheduler)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DelaySubscription(default(IObservable<int>), TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DelaySubscription(default(IObservable<int>), TimeSpan.Zero, Scheduler.Immediate));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.DelaySubscription(DummyObservable<int>.Instance, TimeSpan.Zero, default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.DelaySubscription(DummyObservable<int>.Instance, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.DelaySubscription(DummyObservable<int>.Instance, TimeSpan.FromSeconds(-1), Scheduler.Immediate));
- }
- [Fact]
- public void DelaySubscription_TimeSpan_Default()
- {
- var lst = new List<int>();
- Observable.Range(0, 10).DelaySubscription(TimeSpan.FromMilliseconds(1)).ForEach(lst.Add);
- Assert.True(Enumerable.Range(0, 10).SequenceEqual(lst));
- }
- [Fact]
- public void DelaySubscription_TimeSpan_Simple()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateColdObservable(
- OnNext(50, 42),
- OnNext(60, 43),
- OnCompleted<int>(70)
- );
- var res = scheduler.Start(() =>
- xs.DelaySubscription(TimeSpan.FromTicks(30), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(280, 42),
- OnNext(290, 43),
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(230, 300)
- );
- }
- [Fact]
- public void DelaySubscription_TimeSpan_Error()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateColdObservable(
- OnNext(50, 42),
- OnNext(60, 43),
- OnError<int>(70, ex)
- );
- var res = scheduler.Start(() =>
- xs.DelaySubscription(TimeSpan.FromTicks(30), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(280, 42),
- OnNext(290, 43),
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(230, 300)
- );
- }
- [Fact]
- public void DelaySubscription_DateTimeOffset_Default()
- {
- var lst = new List<int>();
- Observable.Range(0, 10).DelaySubscription(DateTimeOffset.UtcNow.AddMilliseconds(1)).ForEach(lst.Add);
- Assert.True(Enumerable.Range(0, 10).SequenceEqual(lst));
- }
- [Fact]
- public void DelaySubscription_DateTimeOffset_Simple()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateColdObservable(
- OnNext(50, 42),
- OnNext(60, 43),
- OnCompleted<int>(70)
- );
- var res = scheduler.Start(() =>
- xs.DelaySubscription(new DateTimeOffset(230, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(280, 42),
- OnNext(290, 43),
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(230, 300)
- );
- }
- [Fact]
- public void DelaySubscription_DateTimeOffset_Error()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateColdObservable(
- OnNext(50, 42),
- OnNext(60, 43),
- OnError<int>(70, ex)
- );
- var res = scheduler.Start(() =>
- xs.DelaySubscription(new DateTimeOffset(230, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(280, 42),
- OnNext(290, 43),
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(230, 300)
- );
- }
- #endregion
- #region + Generate +
- [Fact]
- public void Generate_TimeSpan_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance, (IScheduler)null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, (Func<int, bool>)null, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, (Func<int, int>)null, DummyFunc<int, TimeSpan>.Instance, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, (Func<int, int>)null, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, (Func<int, TimeSpan>)null, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance, DummyScheduler.Instance).Subscribe(null));
- }
- [Fact]
- public void Generate_TimeSpan_Finite()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => x <= 3, x => x + 1, x => x, x => TimeSpan.FromTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(202, 0),
- OnNext(204, 1),
- OnNext(207, 2),
- OnNext(211, 3),
- OnCompleted<int>(211)
- );
- }
- [Fact]
- public void Generate_TimeSpan_Throw_Condition()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, new Func<int, bool>(x => { throw ex; }), x => x + 1, x => x, x => TimeSpan.FromTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(201, ex)
- );
- }
- [Fact]
- public void Generate_TimeSpan_Throw_ResultSelector()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, x => x + 1, new Func<int, int>(x => { throw ex; }), x => TimeSpan.FromTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(201, ex)
- );
- }
- [Fact]
- public void Generate_TimeSpan_Throw_Iterate()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, new Func<int, int>(x => { throw ex; }), x => x, x => TimeSpan.FromTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(202, 0),
- OnError<int>(202, ex)
- );
- }
- [Fact]
- public void Generate_TimeSpan_Throw_TimeSelector()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, x => x + 1, x => x, new Func<int, TimeSpan>(x => { throw ex; }), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(201, ex)
- );
- }
- [Fact]
- public void Generate_TimeSpan_Dispose()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, x => x + 1, x => x, x => TimeSpan.FromTicks(x + 1), scheduler),
- 210
- );
- res.Messages.AssertEqual(
- OnNext(202, 0),
- OnNext(204, 1),
- OnNext(207, 2)
- );
- }
- [Fact]
- public void Generate_TimeSpan_DefaultScheduler_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, (Func<int, bool>)null, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, (Func<int, int>)null, DummyFunc<int, TimeSpan>.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, (Func<int, int>)null, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, (Func<int, TimeSpan>)null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, TimeSpan>.Instance).Subscribe(null));
- }
- [Fact]
- public void Generate_TimeSpan_DefaultScheduler()
- {
- Observable.Generate(0, x => x < 10, x => x + 1, x => x, x => TimeSpan.FromMilliseconds(x)).AssertEqual(Observable.Generate(0, x => x < 10, x => x + 1, x => x, x => TimeSpan.FromMilliseconds(x), DefaultScheduler.Instance));
- }
- [Fact]
- public void Generate_DateTimeOffset_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance, (IScheduler)null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, (Func<int, bool>)null, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, (Func<int, int>)null, DummyFunc<int, DateTimeOffset>.Instance, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, (Func<int, int>)null, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, (Func<int, DateTimeOffset>)null, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance, DummyScheduler.Instance).Subscribe(null));
- }
- [Fact]
- public void Generate_DateTimeOffset_Finite()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => x <= 3, x => x + 1, x => x, x => scheduler.Now.AddTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(202, 0),
- OnNext(204, 1),
- OnNext(207, 2),
- OnNext(211, 3),
- OnCompleted<int>(211)
- );
- }
- [Fact]
- public void Generate_DateTimeOffset_Throw_Condition()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, new Func<int, bool>(x => { throw ex; }), x => x + 1, x => x, x => scheduler.Now.AddTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(201, ex)
- );
- }
- [Fact]
- public void Generate_DateTimeOffset_Throw_ResultSelector()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, x => x + 1, new Func<int, int>(x => { throw ex; }), x => scheduler.Now.AddTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(201, ex)
- );
- }
- [Fact]
- public void Generate_DateTimeOffset_Throw_Iterate()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, new Func<int, int>(x => { throw ex; }), x => x, x => scheduler.Now.AddTicks(x + 1), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(202, 0),
- OnError<int>(202, ex)
- );
- }
- [Fact]
- public void Generate_DateTimeOffset_Throw_TimeSelector()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, x => x + 1, x => x, new Func<int, DateTimeOffset>(x => { throw ex; }), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(201, ex)
- );
- }
- [Fact]
- public void Generate_DateTimeOffset_Dispose()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Generate(0, x => true, x => x + 1, x => x, x => scheduler.Now.AddTicks(x + 1), scheduler),
- 210
- );
- res.Messages.AssertEqual(
- OnNext(202, 0),
- OnNext(204, 1),
- OnNext(207, 2)
- );
- }
- [Fact]
- public void Generate_DateTimeOffset_DefaultScheduler_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, (Func<int, bool>)null, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, (Func<int, int>)null, DummyFunc<int, DateTimeOffset>.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, (Func<int, int>)null, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, (Func<int, DateTimeOffset>)null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Generate(0, DummyFunc<int, bool>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, int>.Instance, DummyFunc<int, DateTimeOffset>.Instance).Subscribe(null));
- }
- [Fact]
- public void Generate_DateTimeOffset_DefaultScheduler()
- {
- Observable.Generate(0, x => x < 10, x => x + 1, x => x, x => DateTimeOffset.Now.AddMilliseconds(x)).AssertEqual(Observable.Generate(0, x => x < 10, x => x + 1, x => x, x => DateTimeOffset.Now.AddMilliseconds(x), DefaultScheduler.Instance));
- }
- #endregion
- #region + Interval +
- [Fact]
- public void Interval_TimeSpan_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Interval(TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Interval(TimeSpan.Zero, DummyScheduler.Instance).Subscribe(null));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Interval(TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Interval(TimeSpan.FromSeconds(-1), DummyScheduler.Instance));
- }
- [Fact]
- public void Interval_TimeSpan_Basic()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Interval(TimeSpan.FromTicks(100), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(300, 0L),
- OnNext(400, 1L),
- OnNext(500, 2L),
- OnNext(600, 3L),
- OnNext(700, 4L),
- OnNext(800, 5L),
- OnNext(900, 6L)
- );
- }
- [Fact]
- public void Interval_TimeSpan_Zero()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Interval(TimeSpan.FromTicks(0), scheduler),
- 210
- );
- res.Messages.AssertEqual(
- OnNext(201, 0L),
- OnNext(202, 1L),
- OnNext(203, 2L),
- OnNext(204, 3L),
- OnNext(205, 4L),
- OnNext(206, 5L),
- OnNext(207, 6L),
- OnNext(208, 7L),
- OnNext(209, 8L)
- );
- }
- [Fact]
- public void Interval_TimeSpan_Zero_DefaultScheduler()
- {
- var scheduler = new TestScheduler();
- var observer = scheduler.CreateObserver<long>();
- var completed = new ManualResetEvent(false);
- Observable.Interval(TimeSpan.Zero).TakeWhile(i => i < 10).Subscribe(observer.OnNext, () => completed.Set());
- completed.WaitOne();
- Assert.Equal(10, observer.Messages.Count);
- }
- [Fact]
- public void Interval_TimeSpan_Disposed()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(
- () => Observable.Interval(TimeSpan.FromTicks(1000), scheduler)
- );
- res.Messages.AssertEqual(
- );
- }
- [Fact]
- public void Interval_TimeSpan_ObserverThrows()
- {
- var scheduler = new TestScheduler();
- var xs = Observable.Interval(TimeSpan.FromTicks(1), scheduler);
- xs.Subscribe(x => { throw new InvalidOperationException(); });
- ReactiveAssert.Throws<InvalidOperationException>(() => scheduler.Start());
- }
- [Fact]
- public void Interval_TimeSpan_DefaultScheduler()
- {
- Assert.True(Observable.Interval(TimeSpan.FromMilliseconds(1)).ToEnumerable().Take(3).SequenceEqual(new[] { 0L, 1L, 2L }));
- }
- #endregion
- #region + Sample +
- [Fact]
- public void Sample_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Sample(default(IObservable<int>), TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Sample(default(IObservable<int>), TimeSpan.Zero, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Sample(someObservable, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Sample(someObservable, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Sample(someObservable, TimeSpan.FromSeconds(-1), scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Sample(default(IObservable<int>), someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Sample(someObservable, default(IObservable<int>)));
- }
- [Fact]
- public void Sample_Regular()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnCompleted<int>(390)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(300, 5), /* CHECK: boundary of sampling */
- OnNext(350, 6),
- OnNext(400, 7), /* Sample in last bucket */
- OnCompleted<int>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 390)
- );
- }
- [Fact]
- public void Sample_Periodic_Regular()
- {
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnCompleted<int>(390)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(300, 5), /* CHECK: boundary of sampling */
- OnNext(350, 6),
- OnNext(400, 7), /* Sample in last bucket */
- OnCompleted<int>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 390)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 400) { 250, 300, 350, 400 }
- );
- #endif
- }
- [Fact]
- public void Sample_ErrorInFlight()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(310, 6),
- OnError<int>(330, ex)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(300, 5), /* CHECK: boundary of sampling */
- OnError<int>(330, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 330)
- );
- }
- [Fact]
- public void Sample_Periodic_ErrorInFlight()
- {
- var scheduler = new PeriodicTestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(310, 6),
- OnError<int>(330, ex)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(300, 5), /* CHECK: boundary of sampling */
- OnError<int>(330, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 330)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 330) { 250, 300 }
- );
- #endif
- }
- [Fact]
- public void Sample_Empty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void Sample_Periodic_Empty()
- {
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 300) { 250, 300 }
- );
- #endif
- }
- [Fact]
- public void Sample_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnError<int>(300, ex)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void Sample_Periodic_Error()
- {
- var scheduler = new PeriodicTestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnError<int>(300, ex)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 300) { 250 }
- );
- #endif
- }
- [Fact]
- public void Sample_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void Sample_Periodic_Never()
- {
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1)
- );
- var res = scheduler.Start(() =>
- xs.Sample(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 1000) { 250, 300, 350, 400, 450, 500, 550, 600, 650, 700, 750, 800, 850, 900, 950 }
- );
- #endif
- }
- [Fact]
- public void Sample_DefaultScheduler_Periodic()
- {
- var res = Observable.Return(42).Sample(TimeSpan.FromMilliseconds(1)).ToEnumerable().Single();
- Assert.Equal(42, res);
- }
- [Fact]
- public void Sample_DefaultScheduler_PeriodicDisabled()
- {
- var res = Observable.Return(42).Sample(TimeSpan.FromMilliseconds(1), Scheduler.Default.DisableOptimizations()).ToEnumerable().Single();
- Assert.Equal(42, res);
- }
- [Fact]
- public void Sample_Sampler_Simple1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(220, 2),
- OnNext(240, 3),
- OnNext(290, 4),
- OnNext(300, 5),
- OnNext(310, 6),
- OnCompleted<int>(400)
- );
- var ys = scheduler.CreateHotObservable(
- OnNext(150, ""),
- OnNext(210, "bar"),
- OnNext(250, "foo"),
- OnNext(260, "qux"),
- OnNext(320, "baz"),
- OnCompleted<string>(500)
- );
- var res = scheduler.Start(() =>
- xs.Sample(ys)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(320, 6),
- OnCompleted<int>(500 /* on sampling boundaries only */)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 500)
- );
- }
- [Fact]
- public void Sample_Sampler_Simple2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(220, 2),
- OnNext(240, 3),
- OnNext(290, 4),
- OnNext(300, 5),
- OnNext(310, 6),
- OnNext(360, 7),
- OnCompleted<int>(400)
- );
- var ys = scheduler.CreateHotObservable(
- OnNext(150, ""),
- OnNext(210, "bar"),
- OnNext(250, "foo"),
- OnNext(260, "qux"),
- OnNext(320, "baz"),
- OnCompleted<string>(500)
- );
- var res = scheduler.Start(() =>
- xs.Sample(ys)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(320, 6),
- OnNext(500, 7),
- OnCompleted<int>(500 /* on sampling boundaries only */)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 500)
- );
- }
- [Fact]
- public void Sample_Sampler_Simple3()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(220, 2),
- OnNext(240, 3),
- OnNext(290, 4),
- OnCompleted<int>(300)
- );
- var ys = scheduler.CreateHotObservable(
- OnNext(150, ""),
- OnNext(210, "bar"),
- OnNext(250, "foo"),
- OnNext(260, "qux"),
- OnNext(320, "baz"),
- OnCompleted<string>(500)
- );
- var res = scheduler.Start(() =>
- xs.Sample(ys)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnNext(320, 4),
- OnCompleted<int>(320 /* on sampling boundaries only */)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 320)
- );
- }
- [Fact]
- public void Sample_Sampler_SourceThrows()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(220, 2),
- OnNext(240, 3),
- OnNext(290, 4),
- OnNext(300, 5),
- OnNext(310, 6),
- OnError<int>(320, ex)
- );
- var ys = scheduler.CreateHotObservable(
- OnNext(150, ""),
- OnNext(210, "bar"),
- OnNext(250, "foo"),
- OnNext(260, "qux"),
- OnNext(330, "baz"),
- OnCompleted<string>(400)
- );
- var res = scheduler.Start(() =>
- xs.Sample(ys)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnError<int>(320, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 320)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 320)
- );
- }
- #if !NO_PERF // BREAKING CHANGE v2 > v1.x - behavior when sampler throws
- [Fact]
- public void Sample_Sampler_SamplerThrows()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(220, 2),
- OnNext(240, 3),
- OnNext(290, 4),
- OnNext(300, 5),
- OnNext(310, 6),
- OnCompleted<int>(400)
- );
- var ys = scheduler.CreateHotObservable(
- OnNext(150, ""),
- OnNext(210, "bar"),
- OnNext(250, "foo"),
- OnNext(260, "qux"),
- OnError<string>(320, ex)
- );
- var res = scheduler.Start(() =>
- xs.Sample(ys)
- );
- res.Messages.AssertEqual(
- OnNext(250, 3),
- OnError<int>(320, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 320)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 320)
- );
- }
- #endif
- #endregion
- #region + Skip +
- [Fact]
- public void Skip_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Skip(default(IObservable<int>), TimeSpan.FromSeconds(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Skip(xs, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Skip(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Skip(xs, TimeSpan.FromSeconds(1), default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Skip(xs, TimeSpan.FromSeconds(-1), Scheduler.Default));
- }
- [Fact]
- public void Skip_Zero()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void Skip_Some()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.FromTicks(15), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void Skip_Late()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void Skip_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void Skip_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void Skip_Twice1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.FromTicks(15), scheduler).Skip(TimeSpan.FromTicks(30), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 270)
- );
- }
- [Fact]
- public void Skip_Twice2()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.Skip(TimeSpan.FromTicks(30), scheduler).Skip(TimeSpan.FromTicks(15), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 270)
- );
- }
- [Fact]
- public void Skip_Default()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.Skip(TimeSpan.FromSeconds(60));
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- #endregion
- #region + SkipLast +
- [Fact]
- public void SkipLast_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.SkipLast(default(IObservable<int>), TimeSpan.FromSeconds(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.SkipLast(xs, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.SkipLast(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.SkipLast(xs, TimeSpan.FromSeconds(1), default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.SkipLast(xs, TimeSpan.FromSeconds(-1), Scheduler.Default));
- }
- [Fact]
- public void SkipLast_Zero1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipLast_Zero2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipLast_Some1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.FromTicks(15), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(230, 1),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipLast_Some2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnNext(270, 7),
- OnNext(280, 8),
- OnNext(290, 9),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.FromTicks(45), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(260, 1),
- OnNext(270, 2),
- OnNext(280, 3),
- OnNext(290, 4),
- OnNext(300, 5),
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void SkipLast_All()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipLast_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void SkipLast_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.SkipLast(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void SkipLast_Default1()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.SkipLast(TimeSpan.FromSeconds(60));
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- [Fact]
- public void SkipLast_Default2()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.SkipLast(TimeSpan.FromSeconds(60), Scheduler.Default.DisableOptimizations());
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- [Fact]
- public void SkipLast_Default3()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.SkipLast(TimeSpan.Zero);
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- [Fact]
- public void SkipLast_Default4()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.SkipLast(TimeSpan.Zero, Scheduler.Default.DisableOptimizations());
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- #endregion
- #region + SkipUntil +
- [Fact]
- public void SkipUntil_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.SkipUntil(default(IObservable<int>), DateTimeOffset.Now));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.SkipUntil(default(IObservable<int>), DateTimeOffset.Now, Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.SkipUntil(xs, DateTimeOffset.Now, default(IScheduler)));
- }
- [Fact]
- public void SkipUntil_Zero()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipUntil_Some()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(215, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipUntil_Late()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(250, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void SkipUntil_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(250, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void SkipUntil_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(250, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void SkipUntil_Twice1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(215, TimeSpan.Zero), scheduler).SkipUntil(new DateTimeOffset(230, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 270)
- );
- }
- [Fact]
- public void SkipUntil_Twice2()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.SkipUntil(new DateTimeOffset(230, TimeSpan.Zero), scheduler).SkipUntil(new DateTimeOffset(215, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 270)
- );
- }
- [Fact]
- public void SkipUntil_Default()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.SkipUntil(DateTimeOffset.UtcNow.AddMinutes(1));
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- #endregion
- #region + Take +
- [Fact]
- public void Take_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Take(default(IObservable<int>), TimeSpan.FromSeconds(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Take(xs, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Take(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Take(xs, TimeSpan.FromSeconds(1), default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Take(xs, TimeSpan.FromSeconds(-1), Scheduler.Default));
- }
- [Fact]
- public void Take_Zero()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(201)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 201)
- );
- }
- [Fact]
- public void Take_Some()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(240)
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(225)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 225)
- );
- }
- [Fact]
- public void Take_Late()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void Take_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void Take_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(250)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 250)
- );
- }
- [Fact]
- public void Take_Twice1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.FromTicks(55), scheduler).Take(TimeSpan.FromTicks(35), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(235)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 235)
- );
- }
- [Fact]
- public void Take_Twice2()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.Take(TimeSpan.FromTicks(35), scheduler).Take(TimeSpan.FromTicks(55), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(235)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 235)
- );
- }
- [Fact]
- public void Take_Default()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.Take(TimeSpan.FromSeconds(60));
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- #endregion
- #region + TakeLast +
- [Fact]
- public void TakeLast_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(default(IObservable<int>), TimeSpan.FromSeconds(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(1), default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(-1), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default, Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(1), default(IScheduler), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(1), Scheduler.Default, default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLast(xs, TimeSpan.FromSeconds(-1), Scheduler.Default, Scheduler.Default));
- }
- [Fact]
- public void TakeLast_Zero1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLast_Zero1_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.Zero, scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(231)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLast_Zero2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLast_Zero2_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.Zero, scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(231)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLast_Some1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(240)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 2),
- OnNext(240, 3),
- OnCompleted<int>(240)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 240)
- );
- }
- [Fact]
- public void TakeLast_Some1_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(240)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(25), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(241, 2),
- OnNext(242, 3),
- OnCompleted<int>(243)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 240)
- );
- }
- [Fact]
- public void TakeLast_Some2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TakeLast_Some2_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(25), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(301)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TakeLast_Some3()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnNext(270, 7),
- OnNext(280, 8),
- OnNext(290, 9),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(45), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(300, 6),
- OnNext(300, 7),
- OnNext(300, 8),
- OnNext(300, 9),
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TakeLast_Some3_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnNext(270, 7),
- OnNext(280, 8),
- OnNext(290, 9),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(45), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(301, 6),
- OnNext(302, 7),
- OnNext(303, 8),
- OnNext(304, 9),
- OnCompleted<int>(305)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TakeLast_Some4()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(250, 3),
- OnNext(280, 4),
- OnNext(290, 5),
- OnNext(300, 6),
- OnCompleted<int>(350)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(350)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 350)
- );
- }
- [Fact]
- public void TakeLast_Some4_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(250, 3),
- OnNext(280, 4),
- OnNext(290, 5),
- OnNext(300, 6),
- OnCompleted<int>(350)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(25), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(351)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 350)
- );
- }
- [Fact]
- public void TakeLast_All()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(230, 1),
- OnNext(230, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLast_All_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(50), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(231, 1),
- OnNext(232, 2),
- OnCompleted<int>(233)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLast_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void TakeLast_Error_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(50), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void TakeLast_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void TakeLast_Never_WithLoopScheduler()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.TakeLast(TimeSpan.FromTicks(50), scheduler, scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void TakeLast_Default1()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLast(TimeSpan.FromSeconds(60));
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- [Fact]
- public void TakeLast_Default2()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLast(TimeSpan.FromSeconds(60), Scheduler.Default.DisableOptimizations());
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- [Fact]
- public void TakeLast_Default3()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLast(TimeSpan.Zero);
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- [Fact]
- public void TakeLast_Default4()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLast(TimeSpan.Zero, Scheduler.Default.DisableOptimizations());
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- [Fact]
- public void TakeLast_LongRunning_Regular()
- {
- var res = Observable.Range(0, 10, Scheduler.Default).TakeLast(TimeSpan.FromSeconds(60), Scheduler.Default, NewThreadScheduler.Default);
- var lst = new List<int>();
- res.ForEach(lst.Add);
- Assert.True(Enumerable.Range(0, 10).SequenceEqual(lst));
- }
- #endregion
- #region + TakeLastBuffer +
- [Fact]
- public void TakeLastBuffer_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLastBuffer(default(IObservable<int>), TimeSpan.FromSeconds(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLastBuffer(xs, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLastBuffer(default(IObservable<int>), TimeSpan.FromSeconds(1), Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeLastBuffer(xs, TimeSpan.FromSeconds(1), default(IScheduler)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.TakeLastBuffer(xs, TimeSpan.FromSeconds(-1), Scheduler.Default));
- }
- [Fact]
- public void TakeLastBuffer_Zero1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(230, lst => lst.Count == 0),
- OnCompleted<IList<int>>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLastBuffer_Zero2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.Zero, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(230, lst => lst.Count == 0),
- OnCompleted<IList<int>>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLastBuffer_Some1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(240)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(240, lst => lst.SequenceEqual(new[] { 2, 3 })),
- OnCompleted<IList<int>>(240)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 240)
- );
- }
- [Fact]
- public void TakeLastBuffer_Some2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(300, lst => lst.Count == 0),
- OnCompleted<IList<int>>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TakeLastBuffer_Some3()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnNext(270, 7),
- OnNext(280, 8),
- OnNext(290, 9),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(45), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(300, lst => lst.SequenceEqual(new[] { 6, 7, 8, 9 })),
- OnCompleted<IList<int>>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TakeLastBuffer_Some4()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(250, 3),
- OnNext(280, 4),
- OnNext(290, 5),
- OnNext(300, 6),
- OnCompleted<int>(350)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(25), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(350, lst => lst.Count == 0),
- OnCompleted<IList<int>>(350)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 350)
- );
- }
- [Fact]
- public void TakeLastBuffer_All()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext<IList<int>>(230, lst => lst.SequenceEqual(new[] { 1, 2 })),
- OnCompleted<IList<int>>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeLastBuffer_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<IList<int>>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void TakeLastBuffer_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.TakeLastBuffer(TimeSpan.FromTicks(50), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void TakeLastBuffer_Default1()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLastBuffer(TimeSpan.FromSeconds(60)).SingleAsync();
- var e = new ManualResetEvent(false);
- var lst = default (IList<int>);
- res.Subscribe(
- x => lst = x,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- [Fact]
- public void TakeLastBuffer_Default2()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLastBuffer(TimeSpan.FromSeconds(60), Scheduler.Default.DisableOptimizations()).SingleAsync();
- var e = new ManualResetEvent(false);
- var lst = default(IList<int>);
- res.Subscribe(
- x => lst = x,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- [Fact]
- public void TakeLastBuffer_Default3()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLastBuffer(TimeSpan.Zero).SingleAsync();
- var e = new ManualResetEvent(false);
- var lst = default(IList<int>);
- res.Subscribe(
- x => lst = x,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- [Fact]
- public void TakeLastBuffer_Default4()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeLastBuffer(TimeSpan.Zero, Scheduler.Default.DisableOptimizations()).SingleAsync();
- var e = new ManualResetEvent(false);
- var lst = default(IList<int>);
- res.Subscribe(
- x => lst = x,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.Count == 0);
- }
- #endregion
- #region + TakeUntil +
- [Fact]
- public void TakeUntil_ArgumentChecking()
- {
- var xs = Observable.Return(42);
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeUntil(default(IObservable<int>), DateTimeOffset.Now));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeUntil(default(IObservable<int>), DateTimeOffset.Now, Scheduler.Default));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TakeUntil(xs, DateTimeOffset.Now, default(IScheduler)));
- }
- [Fact]
- public void TakeUntil_Zero()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(201)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 201)
- );
- }
- [Fact]
- public void TakeUntil_Some()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(240)
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(225, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(225)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 225)
- );
- }
- [Fact]
- public void TakeUntil_Late()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(250, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnCompleted<int>(230)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 230)
- );
- }
- [Fact]
- public void TakeUntil_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnError<int>(210, ex)
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(250, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(210, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 210)
- );
- }
- [Fact]
- public void TakeUntil_Never()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(250, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(250)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 250)
- );
- }
- [Fact]
- public void TakeUntil_Twice1()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(255, TimeSpan.Zero), scheduler).TakeUntil(new DateTimeOffset(235, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(235)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 235)
- );
- }
- [Fact]
- public void TakeUntil_Twice2()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnNext(240, 4),
- OnNext(250, 5),
- OnNext(260, 6),
- OnCompleted<int>(270)
- );
- var res = scheduler.Start(() =>
- xs.TakeUntil(new DateTimeOffset(235, TimeSpan.Zero), scheduler).TakeUntil(new DateTimeOffset(255, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 1),
- OnNext(220, 2),
- OnNext(230, 3),
- OnCompleted<int>(235)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 235)
- );
- }
- [Fact]
- public void TakeUntil_Default()
- {
- var xs = Observable.Range(0, 10, Scheduler.Default);
- var res = xs.TakeUntil(DateTimeOffset.Now.AddMinutes(1));
- var e = new ManualResetEvent(false);
- var lst = new List<int>();
- res.Subscribe(
- lst.Add,
- () => e.Set()
- );
- e.WaitOne();
- Assert.True(lst.SequenceEqual(Enumerable.Range(0, 10)));
- }
- #endregion
- #region + Throttle +
- [Fact]
- public void Throttle_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throttle(default(IObservable<int>), TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throttle(someObservable, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throttle(default(IObservable<int>), TimeSpan.Zero, scheduler));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Throttle(someObservable, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Throttle(someObservable, TimeSpan.FromSeconds(-1), scheduler));
- }
- private IEnumerable<Recorded<Notification<T>>> Generate<T, S>(S seed, Func<S, bool> condition, Func<S, S> iterate, Func<S, Recorded<Notification<T>>> selector, Func<S, Recorded<Notification<T>>> final)
- {
- S s;
- for (s = seed; condition(s); s = iterate(s))
- yield return selector(s);
- yield return final(s);
- }
- [Fact]
- public void Throttle_TimeSpan_AllPass()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(270, 3),
- OnNext(300, 4),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(20), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(230, 1),
- OnNext(260, 2),
- OnNext(290, 3),
- OnNext(320, 4),
- OnCompleted<int>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Throttle_TimeSpan_AllPass_ErrorEnd()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(270, 3),
- OnNext(300, 4),
- OnError<int>(400, ex)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(20), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(230, 1),
- OnNext(260, 2),
- OnNext(290, 3),
- OnNext(320, 4),
- OnError<int>(400, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Throttle_TimeSpan_AllDrop()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(270, 3),
- OnNext(300, 4),
- OnNext(330, 5),
- OnNext(360, 6),
- OnNext(390, 7),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(40), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(400, 7),
- OnCompleted<int>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Throttle_TimeSpan_AllDrop_ErrorEnd()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(270, 3),
- OnNext(300, 4),
- OnNext(330, 5),
- OnNext(360, 6),
- OnNext(390, 7),
- OnError<int>(400, ex)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(40), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(400, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Throttle_Empty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(10), scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void Throttle_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnError<int>(300, ex)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(10), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void Throttle_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(10), scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void Throttle_Simple()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 0),
- OnNext(210, 1),
- OnNext(240, 2),
- OnNext(250, 3),
- OnNext(280, 4),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(TimeSpan.FromTicks(20), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(230, 1),
- OnNext(270, 3),
- OnNext(300, 4),
- OnCompleted<int>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void Throttle_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Throttle(TimeSpan.FromMilliseconds(1)).ToEnumerable().SequenceEqual(new[] { 1 }));
- }
- [Fact]
- public void Throttle_Duration_ArgumentChecking()
- {
- var someObservable = DummyObservable<int>.Instance;
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throttle(default(IObservable<int>), x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Throttle(someObservable, default(Func<int, IObservable<string>>)));
- }
- [Fact]
- public void Throttle_Duration_DelayBehavior()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, -1),
- OnNext(250, 0),
- OnNext(280, 1),
- OnNext(310, 2),
- OnNext(350, 3),
- OnNext(400, 4),
- OnCompleted<int>(550)
- );
- var ys = new[] {
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- };
- var res = scheduler.Start(() =>
- xs.Throttle(x => ys[x])
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 20, 0),
- OnNext<int>(280 + 20, 1),
- OnNext<int>(310 + 20, 2),
- OnNext<int>(350 + 20, 3),
- OnNext<int>(400 + 20, 4),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- ys[0].Subscriptions.AssertEqual(Subscribe(250, 250 + 20));
- ys[1].Subscriptions.AssertEqual(Subscribe(280, 280 + 20));
- ys[2].Subscriptions.AssertEqual(Subscribe(310, 310 + 20));
- ys[3].Subscriptions.AssertEqual(Subscribe(350, 350 + 20));
- ys[4].Subscriptions.AssertEqual(Subscribe(400, 400 + 20));
- }
- [Fact]
- public void Throttle_Duration_ThrottleBehavior()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, -1),
- OnNext(250, 0),
- OnNext(280, 1),
- OnNext(310, 2),
- OnNext(350, 3),
- OnNext(400, 4),
- OnCompleted<int>(550)
- );
- var ys = new[] {
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(40, 42),
- OnNext(45, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(60, 42),
- OnNext(65, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- };
- var res = scheduler.Start(() =>
- xs.Throttle(x => ys[x])
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 20, 0),
- OnNext<int>(310 + 20, 2),
- OnNext<int>(400 + 20, 4),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- ys[0].Subscriptions.AssertEqual(Subscribe(250, 250 + 20));
- ys[1].Subscriptions.AssertEqual(Subscribe(280, 310));
- ys[2].Subscriptions.AssertEqual(Subscribe(310, 310 + 20));
- ys[3].Subscriptions.AssertEqual(Subscribe(350, 400));
- ys[4].Subscriptions.AssertEqual(Subscribe(400, 400 + 20));
- }
- [Fact]
- public void Throttle_Duration_EarlyCompletion()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, -1),
- OnNext(250, 0),
- OnNext(280, 1),
- OnNext(310, 2),
- OnNext(350, 3),
- OnNext(400, 4),
- OnCompleted<int>(410)
- );
- var ys = new[] {
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(40, 42),
- OnNext(45, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(60, 42),
- OnNext(65, 99)
- ),
- scheduler.CreateColdObservable(
- OnNext(20, 42),
- OnNext(25, 99)
- ),
- };
- var res = scheduler.Start(() =>
- xs.Throttle(x => ys[x])
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 20, 0),
- OnNext<int>(310 + 20, 2),
- OnNext<int>(410, 4),
- OnCompleted<int>(410)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 410)
- );
- ys[0].Subscriptions.AssertEqual(Subscribe(250, 250 + 20));
- ys[1].Subscriptions.AssertEqual(Subscribe(280, 310));
- ys[2].Subscriptions.AssertEqual(Subscribe(310, 310 + 20));
- ys[3].Subscriptions.AssertEqual(Subscribe(350, 400));
- ys[4].Subscriptions.AssertEqual(Subscribe(400, 410));
- }
- [Fact]
- public void Throttle_Duration_InnerError()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Throttle(x =>
- x < 4 ? scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- )
- : scheduler.CreateColdObservable(
- OnError<string>(x * 10, ex)
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnError<int>(450 + 4 * 10, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 490)
- );
- }
- [Fact]
- public void Throttle_Duration_OuterError()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnError<int>(460, ex)
- );
- var res = scheduler.Start(() =>
- xs.Throttle(x =>
- scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnError<int>(460, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 460)
- );
- }
- [Fact]
- public void Throttle_Duration_SelectorThrows()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Throttle(x =>
- {
- if (x < 4)
- {
- return scheduler.CreateColdObservable(
- OnNext(x * 10, "Ignore"),
- OnNext(x * 10 + 5, "Aargh!")
- );
- }
- else
- throw ex;
- })
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnError<int>(450, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 450)
- );
- }
- [Fact]
- public void Throttle_Duration_InnerDone_DelayBehavior()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(350, 3),
- OnNext(450, 4),
- OnCompleted<int>(550)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Throttle(x =>
- scheduler.CreateColdObservable(
- OnCompleted<string>(x * 10)
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(350 + 3 * 10, 3),
- OnNext<int>(450 + 4 * 10, 4),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- [Fact]
- public void Throttle_Duration_InnerDone_ThrottleBehavior()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(250, 2),
- OnNext(280, 3),
- OnNext(300, 4),
- OnNext(400, 5),
- OnNext(410, 6),
- OnCompleted<int>(550)
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Throttle(x =>
- scheduler.CreateColdObservable(
- OnCompleted<string>(x * 10)
- )
- )
- );
- res.Messages.AssertEqual(
- OnNext<int>(250 + 2 * 10, 2),
- OnNext<int>(300 + 4 * 10, 4),
- OnNext<int>(410 + 6 * 10, 6),
- OnCompleted<int>(550)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 550)
- );
- }
- #endregion
- #region + TimeInterval +
- [Fact]
- public void TimeInterval_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TimeInterval(default(IObservable<int>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TimeInterval(default(IObservable<int>), scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.TimeInterval(someObservable, null));
- }
- [Fact]
- public void TimeInterval_Regular()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnNext(210, new TimeInterval<int>(2, TimeSpan.FromTicks(10))),
- OnNext(230, new TimeInterval<int>(3, TimeSpan.FromTicks(20))),
- OnNext(260, new TimeInterval<int>(4, TimeSpan.FromTicks(30))),
- OnNext(300, new TimeInterval<int>(5, TimeSpan.FromTicks(40))),
- OnNext(350, new TimeInterval<int>(6, TimeSpan.FromTicks(50))),
- OnCompleted<TimeInterval<int>>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void TimeInterval_Empty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnCompleted<TimeInterval<int>>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TimeInterval_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnError<int>(300, ex)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- OnError<TimeInterval<int>>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TimeInterval_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler.DisableOptimizations())
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void TimeInterval_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).TimeInterval().Count().First() == 1);
- }
- [Fact]
- public void TimeInterval_WithStopwatch_Regular()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, new TimeInterval<int>(2, TimeSpan.FromTicks(10))),
- OnNext(230, new TimeInterval<int>(3, TimeSpan.FromTicks(20))),
- OnNext(260, new TimeInterval<int>(4, TimeSpan.FromTicks(30))),
- OnNext(300, new TimeInterval<int>(5, TimeSpan.FromTicks(40))),
- OnNext(350, new TimeInterval<int>(6, TimeSpan.FromTicks(50))),
- OnCompleted<TimeInterval<int>>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void TimeInterval_WithStopwatch_Empty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnCompleted<int>(300)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<TimeInterval<int>>(300)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TimeInterval_WithStopwatch_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnError<int>(300, ex)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler)
- );
- res.Messages.AssertEqual(
- OnError<TimeInterval<int>>(300, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- }
- [Fact]
- public void TimeInterval_WithStopwatch_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1)
- );
- var res = scheduler.Start(() =>
- xs.TimeInterval(scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- #endregion
- #region + Timeout +
- [Fact]
- public void Timeout_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), TimeSpan.Zero));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), TimeSpan.Zero, someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, TimeSpan.Zero, default(IObservable<int>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), new DateTimeOffset()));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), new DateTimeOffset(), someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, new DateTimeOffset(), default(IObservable<int>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), TimeSpan.Zero, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, TimeSpan.Zero, default(IScheduler)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), TimeSpan.Zero, someObservable, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, TimeSpan.Zero, someObservable, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, TimeSpan.Zero, default(IObservable<int>), scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), new DateTimeOffset(), scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, new DateTimeOffset(), default(IScheduler)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), new DateTimeOffset(), someObservable, scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, new DateTimeOffset(), someObservable, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, new DateTimeOffset(), default(IObservable<int>), scheduler));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timeout(someObservable, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timeout(someObservable, TimeSpan.FromSeconds(-1), scheduler));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timeout(someObservable, TimeSpan.FromSeconds(-1), someObservable));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timeout(someObservable, TimeSpan.FromSeconds(-1), someObservable, scheduler));
- }
- [Fact]
- public void Timeout_InTime()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(500), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnCompleted<int>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Timeout_DateTimeOffset_TimeoutOccurs_WithDefaultException()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(410, 1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(new DateTimeOffset(new DateTime(400), TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(400, ex => ex is TimeoutException)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Timeout_TimeSpan_TimeoutOccurs_WithDefaultException()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(410, 1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(200), scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(400, ex => ex is TimeoutException)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Timeout_TimeSpan_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Timeout(TimeSpan.FromSeconds(10)).ToEnumerable().Single() == 1);
- }
- [Fact]
- public void Timeout_TimeSpan_Observable_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Timeout(TimeSpan.FromSeconds(10), Observable.Return(2)).ToEnumerable().Single() == 1);
- }
- [Fact]
- public void Timeout_DateTimeOffset_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Timeout(DateTimeOffset.UtcNow + TimeSpan.FromSeconds(10)).ToEnumerable().Single() == 1);
- }
- [Fact]
- public void Timeout_DateTimeOffset_Observable_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Timeout(DateTimeOffset.UtcNow + TimeSpan.FromSeconds(10), Observable.Return(2)).ToEnumerable().Single() == 1);
- }
- [Fact]
- public void Timeout_TimeoutOccurs_1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(70, 1),
- OnNext(130, 2),
- OnNext(310, 3),
- OnNext(400, 4),
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(50, -1),
- OnNext(200, -2),
- OnNext(310, -3),
- OnCompleted<int>(320)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(350, -1),
- OnNext(500, -2),
- OnNext(610, -3),
- OnCompleted<int>(620)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(300, 620)
- );
- }
- [Fact]
- public void Timeout_TimeoutOccurs_2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(70, 1),
- OnNext(130, 2),
- OnNext(240, 3),
- OnNext(310, 4),
- OnNext(430, 5),
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(50, -1),
- OnNext(200, -2),
- OnNext(310, -3),
- OnCompleted<int>(320)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 3),
- OnNext(310, 4),
- OnNext(460, -1),
- OnNext(610, -2),
- OnNext(720, -3),
- OnCompleted<int>(730)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 410)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(410, 730)
- );
- }
- [Fact]
- public void Timeout_TimeoutOccurs_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(70, 1),
- OnNext(130, 2),
- OnNext(240, 3),
- OnNext(310, 4),
- OnNext(430, 5),
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 3),
- OnNext(310, 4)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 410)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(410, 1000)
- );
- }
- [Fact]
- public void Timeout_TimeoutOccurs_Completed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(400, -1)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(300, 1000)
- );
- }
- [Fact]
- public void Timeout_TimeoutOccurs_Error()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnError<int>(500, new Exception())
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(400, -1)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(300, 1000)
- );
- }
- [Fact]
- public void Timeout_TimeoutOccurs_NextIsError()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext<int>(500, 42)
- );
- var ys = scheduler.CreateColdObservable(
- OnError<int>(100, ex)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(400, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(300, 400)
- );
- }
- [Fact]
- public void Timeout_TimeoutNotOccurs_Completed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnCompleted<int>(250)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<int>(250)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 250)
- );
- ys.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_TimeoutNotOccurs_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnError<int>(250, ex)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnError<int>(250, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 250)
- );
- ys.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_TimeoutDoesNotOccur()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(70, 1),
- OnNext(130, 2),
- OnNext(240, 3),
- OnNext(320, 4),
- OnNext(410, 5),
- OnCompleted<int>(500)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(50, -1),
- OnNext(200, -2),
- OnNext(310, -3),
- OnCompleted<int>(320)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(TimeSpan.FromTicks(100), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(240, 3),
- OnNext(320, 4),
- OnNext(410, 5),
- OnCompleted<int>(500)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 500)
- );
- ys.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_DateTimeOffset_TimeoutOccurs()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(410, 1)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(new DateTimeOffset(new DateTime(400), TimeSpan.Zero), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(500, -1)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(400, 1000)
- );
- }
- [Fact]
- public void Timeout_DateTimeOffset_TimeoutDoesNotOccur_Completed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnCompleted<int>(390)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(new DateTimeOffset(new DateTime(400), TimeSpan.Zero), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnCompleted<int>(390)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 390)
- );
- ys.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_DateTimeOffset_TimeoutDoesNotOccur_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnError<int>(390, ex)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(new DateTimeOffset(new DateTime(400), TimeSpan.Zero), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnError<int>(390, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 390)
- );
- ys.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_DateTimeOffset_TimeoutOccur_2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable(
- OnNext(100, -1)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(new DateTimeOffset(new DateTime(400), TimeSpan.Zero), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(500, -1)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(400, 1000)
- );
- }
- [Fact]
- public void Timeout_DateTimeOffset_TimeoutOccur_3()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.Timeout(new DateTimeOffset(new DateTime(400), TimeSpan.Zero), ys, scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(400, 1000)
- );
- }
- [Fact]
- public void Timeout_Duration_ArgumentChecking()
- {
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), someObservable, x => someObservable, someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, default(IObservable<int>), x => someObservable, someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, someObservable, default(Func<int, IObservable<int>>), someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, someObservable, x => someObservable, default(IObservable<int>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), someObservable, x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, default(IObservable<int>), x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, someObservable, default(Func<int, IObservable<int>>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), x => someObservable, someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, default(Func<int, IObservable<int>>), someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, x => someObservable, default(IObservable<int>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(default(IObservable<int>), x => someObservable));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timeout(someObservable, default(Func<int, IObservable<int>>)));
- }
- [Fact]
- public void Timeout_Duration_Simple_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<int>(
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, _ => ys)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 450)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310),
- Subscribe(310, 350),
- Subscribe(350, 420),
- Subscribe(420, 450)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutFirst()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- OnNext(100, "Boo!")
- );
- var zs = scheduler.CreateColdObservable<string>(
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, _ => zs)
- );
- res.Messages.AssertEqual(
- OnError<int>(300, ex => ex is TimeoutException)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- zs.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutFirst_Other()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- OnNext(100, "Boo!")
- );
- var zs = scheduler.CreateColdObservable<string>(
- );
- var ts = scheduler.CreateColdObservable<int>(
- OnNext(50, 42),
- OnCompleted<int>(70)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, _ => zs, ts)
- );
- res.Messages.AssertEqual(
- OnNext(350, 42),
- OnCompleted<int>(370)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 300)
- );
- zs.Subscriptions.AssertEqual(
- );
- ts.Subscriptions.AssertEqual(
- Subscribe(300, 370)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutLater()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- );
- var zs = scheduler.CreateColdObservable<string>(
- OnNext(50, "Boo!")
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, _ => zs)
- );
- res.Messages.AssertEqual(
- OnNext<int>(310, 1),
- OnNext<int>(350, 2),
- OnError<int>(400, ex => ex is TimeoutException)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 400)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutLater_Other()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- );
- var zs = scheduler.CreateColdObservable<string>(
- OnNext(50, "Boo!")
- );
- var ts = scheduler.CreateColdObservable<int>(
- OnNext(50, 42),
- OnCompleted<int>(70)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, _ => zs, ts)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(450, 42),
- OnCompleted<int>(470)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 400)
- );
- ts.Subscriptions.AssertEqual(
- Subscribe(400, 470)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutLater_NoFirst()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var zs = scheduler.CreateColdObservable<string>(
- OnNext(50, "Boo!")
- );
- var res = scheduler.Start(() =>
- xs.Timeout(_ => zs)
- );
- res.Messages.AssertEqual(
- OnNext<int>(310, 1),
- OnNext<int>(350, 2),
- OnError<int>(400, ex => ex is TimeoutException)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 400)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutLater_Other_NoFirst()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var zs = scheduler.CreateColdObservable<string>(
- OnNext(50, "Boo!")
- );
- var ts = scheduler.CreateColdObservable<int>(
- OnNext(50, 42),
- OnCompleted<int>(70)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(_ => zs, ts)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(450, 42),
- OnCompleted<int>(470)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 400)
- );
- ts.Subscriptions.AssertEqual(
- Subscribe(400, 470)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_TimeoutByCompletion()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- );
- var zs = scheduler.CreateColdObservable<string>(
- OnCompleted<string>(50)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, _ => zs)
- );
- res.Messages.AssertEqual(
- OnNext<int>(310, 1),
- OnNext<int>(350, 2),
- OnError<int>(400, ex => ex is TimeoutException)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 400)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_SelectorThrows()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- );
- var zs = scheduler.CreateColdObservable<string>(
- );
- var ex = new Exception();
- var res = scheduler.Start(() =>
- xs.Timeout(ys, x =>
- {
- if (x < 3)
- return zs;
- else
- throw ex;
- })
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnError<int>(420, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 420)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 420)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_InnerThrows()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- );
- var zs = scheduler.CreateColdObservable<string>(
- OnError<string>(50, ex)
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, x => zs)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnError<int>(400, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 400)
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_FirstThrows()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnCompleted<int>(450)
- );
- var ys = scheduler.CreateColdObservable<string>(
- OnError<string>(50, ex)
- );
- var zs = scheduler.CreateColdObservable<string>(
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, x => zs)
- );
- res.Messages.AssertEqual(
- OnError<int>(250, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 250)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 250)
- );
- zs.Subscriptions.AssertEqual(
- );
- }
- [Fact]
- public void Timeout_Duration_Simple_SourceThrows()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnError<int>(450, ex)
- );
- var ys = scheduler.CreateColdObservable<string>(
- );
- var zs = scheduler.CreateColdObservable<string>(
- );
- var res = scheduler.Start(() =>
- xs.Timeout(ys, x => zs)
- );
- res.Messages.AssertEqual(
- OnNext(310, 1),
- OnNext(350, 2),
- OnNext(420, 3),
- OnError<int>(450, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 450)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 310)
- );
- zs.Subscriptions.AssertEqual(
- Subscribe(310, 350),
- Subscribe(350, 420),
- Subscribe(420, 450)
- );
- }
- #endregion
- #region + Timer +
- [Fact]
- public void OneShotTimer_TimeSpan_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timer(TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timer(TimeSpan.Zero, DummyScheduler.Instance).Subscribe(null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timer(DateTimeOffset.Now, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timer(TimeSpan.Zero, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timer(DateTimeOffset.Now, TimeSpan.Zero, null));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timer(TimeSpan.Zero, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timer(TimeSpan.Zero, TimeSpan.FromSeconds(-1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timer(DateTimeOffset.Now, TimeSpan.FromSeconds(-1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Timer(DateTimeOffset.Now, TimeSpan.FromSeconds(-1), DummyScheduler.Instance));
- }
- [Fact]
- public void OneShotTimer_TimeSpan_Basic()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(300), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(500, 0L),
- OnCompleted<long>(500)
- );
- }
- [Fact]
- public void OneShotTimer_TimeSpan_Zero()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(0), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(201, 0L),
- OnCompleted<long>(201)
- );
- }
- [Fact]
- public void OneShotTimer_TimeSpan_Zero_DefaultScheduler()
- {
- var scheduler = new TestScheduler();
- var observer = scheduler.CreateObserver<long>();
- var completed = new ManualResetEvent(false);
- Observable.Timer(TimeSpan.Zero).Subscribe(observer.OnNext, () => completed.Set());
- completed.WaitOne();
-
- Assert.Equal(1, observer.Messages.Count);
- }
- [Fact]
- public void OneShotTimer_TimeSpan_Negative()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(-1), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(201, 0L),
- OnCompleted<long>(201)
- );
- }
- [Fact]
- public void OneShotTimer_TimeSpan_Disposed()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(1000), scheduler)
- );
- res.Messages.AssertEqual(
- );
- }
- [Fact]
- public void OneShotTimer_TimeSpan_ObserverThrows()
- {
- var scheduler1 = new TestScheduler();
- var xs = Observable.Timer(TimeSpan.FromTicks(1), scheduler1);
- xs.Subscribe(x => { throw new InvalidOperationException(); });
- ReactiveAssert.Throws<InvalidOperationException>(() => scheduler1.Start());
- var scheduler2 = new TestScheduler();
- var ys = Observable.Timer(TimeSpan.FromTicks(1), scheduler2);
- ys.Subscribe(x => { }, ex => { }, () => { throw new InvalidOperationException(); });
- ReactiveAssert.Throws<InvalidOperationException>(() => scheduler2.Start());
- }
- [Fact]
- public void OneShotTimer_TimeSpan_DefaultScheduler()
- {
- Assert.True(Observable.Timer(TimeSpan.FromMilliseconds(1)).ToEnumerable().SequenceEqual(new[] { 0L }));
- }
- [Fact]
- public void OneShotTimer_DateTimeOffset_DefaultScheduler()
- {
- Assert.True(Observable.Timer(DateTimeOffset.UtcNow + TimeSpan.FromSeconds(1)).ToEnumerable().SequenceEqual(new[] { 0L }));
- }
- [Fact]
- public void OneShotTimer_TimeSpan_TimeSpan_DefaultScheduler()
- {
- Assert.True(Observable.Timer(TimeSpan.FromMilliseconds(1), TimeSpan.FromMilliseconds(1)).ToEnumerable().Take(2).SequenceEqual(new[] { 0L, 1L }));
- }
- [Fact]
- public void OneShotTimer_DateTimeOffset_TimeSpan_DefaultScheduler()
- {
- Assert.True(Observable.Timer(DateTimeOffset.UtcNow + TimeSpan.FromSeconds(1), TimeSpan.FromMilliseconds(1)).ToEnumerable().Take(2).SequenceEqual(new[] { 0L, 1L }));
- }
- [Fact]
- public void OneShotTimer_DateTimeOffset_Basic()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(new DateTimeOffset(500, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(500, 0L),
- OnCompleted<long>(500)
- );
- }
- [Fact]
- public void OneShotTimer_DateTimeOffset_Zero()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(new DateTimeOffset(200, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(201, 0L),
- OnCompleted<long>(201)
- );
- }
- [Fact]
- public void OneShotTimer_DateTimeOffset_Past()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(new DateTimeOffset(0, TimeSpan.Zero), scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(201, 0L),
- OnCompleted<long>(201)
- );
- }
- [Fact]
- public void RepeatingTimer_TimeSpan_Zero_DefaultScheduler()
- {
- var scheduler = new TestScheduler();
- var observer = scheduler.CreateObserver<long>();
- var completed = new ManualResetEvent(false);
- Observable.Timer(TimeSpan.Zero, TimeSpan.Zero).TakeWhile(i => i < 10).Subscribe(observer.OnNext, () => completed.Set());
- completed.WaitOne();
- Assert.Equal(10, observer.Messages.Count);
- }
- [Fact]
- public void RepeatingTimer_DateTimeOffset_TimeSpan_Simple()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(new DateTimeOffset(300, TimeSpan.Zero), TimeSpan.FromTicks(100), scheduler),
- 0, 200, 750
- );
- res.Messages.AssertEqual(
- OnNext(300, 0L),
- OnNext(400, 1L),
- OnNext(500, 2L),
- OnNext(600, 3L),
- OnNext(700, 4L)
- );
- }
- [Fact]
- public void RepeatingTimer_TimeSpan_TimeSpan_Simple()
- {
- var scheduler = new TestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(100), scheduler),
- 0, 200, 750
- );
- res.Messages.AssertEqual(
- OnNext(300, 0L),
- OnNext(400, 1L),
- OnNext(500, 2L),
- OnNext(600, 3L),
- OnNext(700, 4L)
- );
- }
- [Fact]
- public void RepeatingTimer_Periodic1()
- {
- var scheduler = new PeriodicTestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(50), TimeSpan.FromTicks(100), scheduler),
- 0, 200, 700
- );
- res.Messages.AssertEqual(
- OnNext(250, 0L),
- OnNext(350, 1L),
- OnNext(450, 2L),
- OnNext(550, 3L),
- OnNext(650, 4L)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(250, 700) { 350, 450, 550, 650 }
- );
- #endif
- }
- [Fact]
- public void RepeatingTimer_Periodic2()
- {
- var scheduler = new PeriodicTestScheduler();
- var res = scheduler.Start(() =>
- Observable.Timer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(100), scheduler),
- 0, 200, 750
- );
- res.Messages.AssertEqual(
- OnNext(300, 0L),
- OnNext(400, 1L),
- OnNext(500, 2L),
- OnNext(600, 3L),
- OnNext(700, 4L)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 750) { 300, 400, 500, 600, 700 }
- );
- #endif
- }
- [Fact]
- public void RepeatingTimer_UsingStopwatch_Slippage1()
- {
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromTicks(100), scheduler); });
- var times = new List<long>();
- var onNext = new Action<long>(x =>
- {
- times.Add(scheduler.Clock);
- if (x == 0)
- {
- return;
- }
- if (x < 2)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 4)
- {
- scheduler.Sleep(120);
- return;
- }
- if (x < 6)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 8)
- {
- return;
- }
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- scheduler.Start();
- times.AssertEqual(
- 201, // 1 off because of initial scheduling jump (InvokeStart)
- 301,
- 401,
- 522, // 2 off because of 401 + 120 + 1 scheduling tick
- 643, // 3 off because of 522 + 120 + 1 scheduling tick
- 701,
- 801,
- 901
- );
- }
- [Fact]
- public void RepeatingTimer_UsingStopwatch_Slippage2()
- {
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(100), scheduler); });
- var times = new List<long>();
- var onNext = new Action<long>(x =>
- {
- times.Add(scheduler.Clock);
- if (x == 0)
- {
- return;
- }
- if (x < 2)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 4)
- {
- scheduler.Sleep(120);
- return;
- }
- if (x < 6)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 8)
- {
- return;
- }
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- scheduler.Start();
- times.AssertEqual(
- 300,
- 400,
- 500,
- 621, // 1 off because of recursive scheduling beyond the target time
- 742, // 2 off because of 621 + 120 + 1 scheduling tick
- 800,
- 900
- );
- }
- [Fact]
- public void RepeatingTimer_UsingStopwatch_Slippage3_CatchUpFromLongInvokeStart()
- {
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromTicks(100), scheduler); });
- var times = new List<long>();
- var onNext = new Action<long>(x =>
- {
- times.Add(scheduler.Clock);
- if (x == 0)
- {
- scheduler.Sleep(350);
- return;
- }
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- scheduler.Start();
- times.AssertEqual(
- 201, // 1 off because of initial scheduling jump (InvokeStart)
- 551, // catching up after excessive delay of 350 (target was 300)
- 552, // catching up after excessive delay of 350 (target was 400)
- 553, // catching up after excessive delay of 350 (target was 500)
- 601, // back in sync
- 701,
- 801,
- 901
- );
- }
- [Fact]
- public void RepeatingTimer_UsingStopwatch_Slippage3_CatchUpFromLongInvokeStart_ThrowsFirst()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromTicks(100), scheduler); });
- var onNext = new Action<long>(x =>
- {
- if (x == 0)
- throw ex;
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- try
- {
- scheduler.Start();
- }
- catch (Exception e)
- {
- Assert.Equal(201, scheduler.Clock);
- Assert.Same(ex, e);
- }
- }
- [Fact]
- public void RepeatingTimer_UsingStopwatch_Slippage3_CatchUpFromLongInvokeStart_ThrowsBeyondFirst()
- {
- var ex = new Exception();
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromTicks(100), scheduler); });
- var times = new List<long>();
- var onNext = new Action<long>(x =>
- {
- times.Add(scheduler.Clock);
- if (x == 0)
- {
- scheduler.Sleep(350);
- return;
- }
- if (x == 5)
- throw ex;
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- try
- {
- scheduler.Start();
- }
- catch (Exception e)
- {
- Assert.Equal(701, scheduler.Clock);
- Assert.Same(ex, e);
- }
- times.AssertEqual(
- 201, // 1 off because of initial scheduling jump (InvokeStart)
- 551, // catching up after excessive delay of 350 (target was 300)
- 552, // catching up after excessive delay of 350 (target was 400)
- 553, // catching up after excessive delay of 350 (target was 500)
- 601, // back in sync
- 701
- );
- }
- [Fact]
- public void RepeatingTimer_NoStopwatch_Slippage1()
- {
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromTicks(100), scheduler.DisableOptimizations(typeof(IStopwatchProvider))); });
- var times = new List<long>();
- var onNext = new Action<long>(x =>
- {
- times.Add(scheduler.Clock);
- if (x == 0)
- {
- return;
- }
- if (x < 2)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 4)
- {
- scheduler.Sleep(120);
- return;
- }
- if (x < 6)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 8)
- {
- return;
- }
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- scheduler.Start();
- times.AssertEqual(
- 201, // 1 off because of initial scheduling jump (InvokeStart)
- 301,
- 401,
- 523, // 3 off because of 401 + 120 + 2 scheduling ticks (one due to yield in SchedulePeriodic emulation code)
- 645, // 5 off because of 523 + 120 + 2 scheduling ticks (one due to yield in SchedulePeriodic emulation code)
- 743, // \
- 843, // +--> 43 off because this situation (no stopwatch or periodic scheduling interface) only gets best effort treatment (see SchedulePeriodic emulation code)
- 943 // /
- );
- }
- [Fact]
- public void RepeatingTimer_NoStopwatch_Slippage2()
- {
- var scheduler = new TestScheduler();
- var xs = default(IObservable<long>);
- scheduler.ScheduleAbsolute(100, () => { xs = Observable.Timer(TimeSpan.FromTicks(100), TimeSpan.FromTicks(100), scheduler.DisableOptimizations(typeof(IStopwatchProvider))); });
- var times = new List<long>();
- var onNext = new Action<long>(x =>
- {
- times.Add(scheduler.Clock);
- if (x == 0)
- {
- return;
- }
- if (x < 2)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 4)
- {
- scheduler.Sleep(120);
- return;
- }
- if (x < 6)
- {
- scheduler.Sleep(50);
- return;
- }
- if (x < 8)
- {
- return;
- }
- });
- var d = default(IDisposable);
- scheduler.ScheduleAbsolute(200, () => { d = xs.Subscribe(onNext); });
- scheduler.ScheduleAbsolute(1000, () => { d.Dispose(); });
- scheduler.Start();
- times.AssertEqual(
- 300,
- 400,
- 500,
- 622, // 2 off because of 500 + 120 + 2 scheduling ticks (one due to yield in SchedulePeriodic emulation code)
- 744, // 4 off because of 622 + 120 + 2 scheduling ticks (one due to yield in SchedulePeriodic emulation code)
- 842, // |
- 942 // +--> 42 off because this situation (no stopwatch or periodic scheduling interface) only gets best effort treatment (see SchedulePeriodic emulation code)
- );
- }
- #if !NO_THREAD
- [Fact]
- public void RepeatingTimer_Start_CatchUp()
- {
- var e = new ManualResetEvent(false);
- var xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromMilliseconds(10));
- var d = new SingleAssignmentDisposable();
- d.Disposable = xs.Subscribe(x =>
- {
- if (x == 0)
- Thread.Sleep(500);
- if (x > 10)
- {
- e.Set();
- d.Dispose();
- }
- });
- e.WaitOne();
- }
- [Fact]
- public void RepeatingTimer_Start_CatchUp_Throws()
- {
- var end = new ManualResetEvent(false);
- var err = new Exception();
- var ex = default(Exception);
- var s = ThreadPoolScheduler.Instance.Catch<Exception>(e =>
- {
- Interlocked.Exchange(ref ex, e);
- end.Set();
- return true;
- });
- var xs = Observable.Timer(TimeSpan.Zero, TimeSpan.FromMilliseconds(10), s);
- xs.Subscribe(x =>
- {
- if (x == 0)
- Thread.Sleep(500);
- if (x == 5)
- throw err;
- });
- end.WaitOne();
- Assert.Same(err, ex);
- }
- #endif
- class SchedulerWithCatch : IServiceProvider, IScheduler
- {
- private readonly IScheduler _scheduler;
- private readonly Action<Exception> _setException;
- public SchedulerWithCatch(IScheduler scheduler, Action<Exception> setException)
- {
- _scheduler = scheduler;
- _setException = setException;
- }
- public object GetService(Type serviceType)
- {
- return ((IServiceProvider)_scheduler).GetService(serviceType);
- }
- public DateTimeOffset Now
- {
- get { return _scheduler.Now; }
- }
- public IDisposable Schedule<TState>(TState state, Func<IScheduler, TState, IDisposable> action)
- {
- return _scheduler.Schedule<TState>(state, GetCatch(action));
- }
- public IDisposable Schedule<TState>(TState state, TimeSpan dueTime, Func<IScheduler, TState, IDisposable> action)
- {
- return _scheduler.Schedule<TState>(state, dueTime, GetCatch(action));
- }
- public IDisposable Schedule<TState>(TState state, DateTimeOffset dueTime, Func<IScheduler, TState, IDisposable> action)
- {
- return _scheduler.Schedule<TState>(state, dueTime, GetCatch(action));
- }
- private Func<IScheduler, TState, IDisposable> GetCatch<TState>(Func<IScheduler, TState, IDisposable> action)
- {
- return (self, s) =>
- {
- try
- {
- return action(new SchedulerWithCatch(self, _setException), s);
- }
- catch (Exception ex)
- {
- _setException(ex);
- return Disposable.Empty;
- }
- };
- }
- }
- class PeriodicTestScheduler : TestScheduler, ISchedulerPeriodic, IServiceProvider
- {
- private readonly List<TimerRun> _timers;
- public PeriodicTestScheduler()
- {
- _timers = new List<TimerRun>();
- }
- public IDisposable SchedulePeriodic<TState>(TState state, TimeSpan period, Func<TState, TState> action)
- {
- var run = new TimerRun(this.Clock);
- _timers.Add(run);
- var x = state;
- var d = this.Schedule(period, self =>
- {
- run.Add(this.Clock);
- x = action(x);
- self(period);
- });
- return new CompositeDisposable(
- Disposable.Create(() => { run.Stop(this.Clock); }),
- d
- );
- }
- public List<TimerRun> Timers
- {
- get { return _timers; }
- }
- protected override object GetService(Type serviceType)
- {
- if (serviceType == typeof(ISchedulerPeriodic))
- return this as ISchedulerPeriodic;
- return base.GetService(serviceType);
- }
- }
- class TimerRun : IEnumerable<long>
- {
- private readonly long _started;
- private long _stopped;
- private bool _hasStopped;
- private readonly List<long> _ticks;
- public TimerRun(long started)
- {
- _started = started;
- _ticks = new List<long>();
- }
- public TimerRun(long started, long stopped)
- {
- _started = started;
- _stopped = stopped;
- _hasStopped = true;
- _ticks = new List<long>();
- }
- public override int GetHashCode()
- {
- return 0;
- }
- public override bool Equals(object obj)
- {
- var other = obj as TimerRun;
- if (other == null)
- return false;
- return _started == other._started && _stopped == other._stopped && _ticks.SequenceEqual(other._ticks);
- }
- public long Started
- {
- get { return _started; }
- }
- public IEnumerable<long> Ticks
- {
- get { return _ticks; }
- }
- public long Stopped
- {
- get { return _stopped; }
- }
- internal void Stop(long clock)
- {
- _stopped = clock;
- _hasStopped = true;
- }
- public override string ToString()
- {
- var sb = new StringBuilder();
- sb.Append("Start(" + _started + ") ");
- sb.Append("Ticks(" + string.Join(", ", _ticks.Select(t => t.ToString()).ToArray()) + ") ");
- if (_hasStopped)
- sb.Append("Stop(" + _stopped + ")");
- return sb.ToString();
- }
- public IEnumerator<long> GetEnumerator()
- {
- return _ticks.GetEnumerator();
- }
- System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator()
- {
- return _ticks.GetEnumerator();
- }
- public void Add(long clock)
- {
- _ticks.Add(clock);
- }
- }
- #endregion
- #region + Timestamp +
- [Fact]
- public void Timestamp_ArgumentChecking()
- {
- var scheduler = new TestScheduler();
- var someObservable = Observable.Empty<int>();
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timestamp(default(IObservable<int>)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timestamp(default(IObservable<int>), scheduler));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Timestamp(someObservable, null));
- }
- [Fact]
- public void Timestamp_Regular()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(230, 3),
- OnNext(260, 4),
- OnNext(300, 5),
- OnNext(350, 6),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.Timestamp(scheduler)
- );
- res.Messages.AssertEqual(
- OnNext(210, new Timestamped<int>(2, new DateTimeOffset(210, TimeSpan.Zero))),
- OnNext(230, new Timestamped<int>(3, new DateTimeOffset(230, TimeSpan.Zero))),
- OnNext(260, new Timestamped<int>(4, new DateTimeOffset(260, TimeSpan.Zero))),
- OnNext(300, new Timestamped<int>(5, new DateTimeOffset(300, TimeSpan.Zero))),
- OnNext(350, new Timestamped<int>(6, new DateTimeOffset(350, TimeSpan.Zero))),
- OnCompleted<Timestamped<int>>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Timestamp_Empty()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(150, 1),
- OnCompleted<int>(400)
- );
- var res = scheduler.Start(() =>
- xs.Timestamp(scheduler)
- );
- res.Messages.AssertEqual(
- OnCompleted<Timestamped<int>>(400)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Timestamp_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(150, 1),
- OnError<int>(400, ex)
- );
- var res = scheduler.Start(() =>
- xs.Timestamp(scheduler)
- );
- res.Messages.AssertEqual(
- OnError<Timestamped<int>>(400, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 400)
- );
- }
- [Fact]
- public void Timestamp_Never()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable<int>(
- OnNext(150, 1)
- );
- var res = scheduler.Start(() =>
- xs.Timestamp(scheduler)
- );
- res.Messages.AssertEqual(
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 1000)
- );
- }
- [Fact]
- public void Timestamp_DefaultScheduler()
- {
- Assert.True(Observable.Return(1).Timestamp().Count().First() == 1);
- }
- #endregion
- #region + Window +
- [Fact]
- public void Window_Time_Basic()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(270, 4),
- OnNext(320, 5),
- OnNext(360, 6),
- OnNext(390, 7),
- OnNext(410, 8),
- OnNext(460, 9),
- OnNext(470, 10),
- OnCompleted<int>(490)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), scheduler).Select((ys, i) => ys.Select(y => i + " " + y).Concat(Observable.Return(i + " end"))).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(270, "0 4"),
- OnNext(300, "0 end"),
- OnNext(320, "1 5"),
- OnNext(360, "1 6"),
- OnNext(390, "1 7"),
- OnNext(400, "1 end"),
- OnNext(410, "2 8"),
- OnNext(460, "2 9"),
- OnNext(470, "2 10"),
- OnNext(490, "2 end"),
- OnCompleted<string>(490)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 490)
- );
- }
- [Fact]
- public void Window_Time_Basic_Periodic()
- {
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(270, 4),
- OnNext(320, 5),
- OnNext(360, 6),
- OnNext(390, 7),
- OnNext(410, 8),
- OnNext(460, 9),
- OnNext(470, 10),
- OnCompleted<int>(490)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), scheduler).Select((ys, i) => ys.Select(y => i + " " + y).Concat(Observable.Return(i + " end"))).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(270, "0 4"),
- OnNext(300, "0 end"),
- OnNext(320, "1 5"),
- OnNext(360, "1 6"),
- OnNext(390, "1 7"),
- OnNext(400, "1 end"),
- OnNext(410, "2 8"),
- OnNext(460, "2 9"),
- OnNext(470, "2 10"),
- OnNext(490, "2 end"),
- OnCompleted<string>(490)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 490)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 490) { 300, 400 }
- );
- #endif
- }
- [Fact]
- public void Window_Time_Basic_Periodic_Error()
- {
- var ex = new Exception();
- var scheduler = new PeriodicTestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(270, 4),
- OnNext(320, 5),
- OnNext(360, 6),
- OnNext(390, 7),
- OnNext(410, 8),
- OnError<int>(460, ex)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), scheduler).Select((ys, i) => ys.Select(y => i + " " + y).Concat(Observable.Return(i + " end"))).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(270, "0 4"),
- OnNext(300, "0 end"),
- OnNext(320, "1 5"),
- OnNext(360, "1 6"),
- OnNext(390, "1 7"),
- OnNext(400, "1 end"),
- OnNext(410, "2 8"),
- OnError<string>(460, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 460)
- );
- #if !WINDOWS
- scheduler.Timers.AssertEqual(
- new TimerRun(200, 460) { 300, 400 }
- );
- #endif
- }
- [Fact]
- public void Window_Time_Basic_Both()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(270, 4),
- OnNext(320, 5),
- OnNext(360, 6),
- OnNext(390, 7),
- OnNext(410, 8),
- OnNext(460, 9),
- OnNext(470, 10),
- OnCompleted<int>(490)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), TimeSpan.FromTicks(50), scheduler).Select((ys, i) => ys.Select(y => i + " " + y).Concat(Observable.Return(i + " end"))).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(270, "0 4"),
- OnNext(270, "1 4"),
- OnNext(300, "0 end"),
- OnNext(320, "1 5"),
- OnNext(320, "2 5"),
- OnNext(350, "1 end"),
- OnNext(360, "2 6"),
- OnNext(360, "3 6"),
- OnNext(390, "2 7"),
- OnNext(390, "3 7"),
- OnNext(400, "2 end"),
- OnNext(410, "3 8"),
- OnNext(410, "4 8"),
- OnNext(450, "3 end"),
- OnNext(460, "4 9"),
- OnNext(460, "5 9"),
- OnNext(470, "4 10"),
- OnNext(470, "5 10"),
- OnNext(490, "4 end"),
- OnNext(490, "5 end"),
- OnCompleted<string>(490)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 490)
- );
- }
- [Fact]
- public void WindowWithTime_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(default(IObservable<int>), TimeSpan.FromTicks(1), TimeSpan.FromTicks(1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), TimeSpan.FromTicks(1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), TimeSpan.FromTicks(-1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), TimeSpan.FromTicks(1), null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(default(IObservable<int>), TimeSpan.FromTicks(1), TimeSpan.FromTicks(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), TimeSpan.FromTicks(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), TimeSpan.FromTicks(-1)));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(default(IObservable<int>), TimeSpan.FromTicks(1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(default(IObservable<int>), TimeSpan.FromTicks(1)));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1)));
- }
- [Fact]
- public void WindowWithTime_Basic1()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), TimeSpan.FromTicks(70), scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "0 4"),
- OnNext(280, "1 4"),
- OnNext(320, "1 5"),
- OnNext(350, "1 6"),
- OnNext(350, "2 6"),
- OnNext(380, "2 7"),
- OnNext(420, "2 8"),
- OnNext(420, "3 8"),
- OnNext(470, "3 9"),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void WindowWithTime_Basic2()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(70), TimeSpan.FromTicks(100), scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(320, "1 5"),
- OnNext(350, "1 6"),
- OnNext(420, "2 8"),
- OnNext(470, "2 9"),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void WindowWithTime_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnError<int>(600, ex)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), TimeSpan.FromTicks(70), scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "0 4"),
- OnNext(280, "1 4"),
- OnNext(320, "1 5"),
- OnNext(350, "1 6"),
- OnNext(350, "2 6"),
- OnNext(380, "2 7"),
- OnNext(420, "2 8"),
- OnNext(420, "3 8"),
- OnNext(470, "3 9"),
- OnError<string>(600, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void WindowWithTime_Disposed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), TimeSpan.FromTicks(70), scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge(),
- 370
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "0 4"),
- OnNext(280, "1 4"),
- OnNext(320, "1 5"),
- OnNext(350, "1 6"),
- OnNext(350, "2 6")
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 370)
- );
- }
- [Fact]
- public void WindowWithTime_Basic_Same()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(100, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(380, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(100), scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "0 4"),
- OnNext(320, "1 5"),
- OnNext(350, "1 6"),
- OnNext(380, "1 7"),
- OnNext(420, "2 8"),
- OnNext(470, "2 9"),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void WindowWithTime_Default()
- {
- Observable.Range(0, 10).Window(TimeSpan.FromDays(1), TimeSpan.FromDays(1)).SelectMany(Observable.ToList).First().AssertEqual(Enumerable.Range(0, 10));
- Observable.Range(0, 10).Window(TimeSpan.FromDays(1)).SelectMany(Observable.ToList).First().AssertEqual(Enumerable.Range(0, 10));
- }
- [Fact]
- public void WindowWithTimeOrCount_ArgumentChecking()
- {
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(default(IObservable<int>), TimeSpan.FromTicks(1), 1, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), 1, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), 0, DummyScheduler.Instance));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), 1, null));
- ReactiveAssert.Throws<ArgumentNullException>(() => Observable.Window(default(IObservable<int>), TimeSpan.FromTicks(1), 1));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(-1), 1));
- ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => Observable.Window(DummyObservable<int>.Instance, TimeSpan.FromTicks(1), 0));
- }
- [Fact]
- public void WindowWithTimeOrCount_Basic()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(205, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(370, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(70), 3, scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(205, "0 1"),
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "1 4"),
- OnNext(320, "2 5"),
- OnNext(350, "2 6"),
- OnNext(370, "2 7"),
- OnNext(420, "3 8"),
- OnNext(470, "4 9"),
- OnCompleted<string>(600)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void WindowWithTimeOrCount_Error()
- {
- var scheduler = new TestScheduler();
- var ex = new Exception();
- var xs = scheduler.CreateHotObservable(
- OnNext(205, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(370, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnError<int>(600, ex)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(70), 3, scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge()
- );
- res.Messages.AssertEqual(
- OnNext(205, "0 1"),
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "1 4"),
- OnNext(320, "2 5"),
- OnNext(350, "2 6"),
- OnNext(370, "2 7"),
- OnNext(420, "3 8"),
- OnNext(470, "4 9"),
- OnError<string>(600, ex)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- }
- [Fact]
- public void WindowWithTimeOrCount_Disposed()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(205, 1),
- OnNext(210, 2),
- OnNext(240, 3),
- OnNext(280, 4),
- OnNext(320, 5),
- OnNext(350, 6),
- OnNext(370, 7),
- OnNext(420, 8),
- OnNext(470, 9),
- OnCompleted<int>(600)
- );
- var res = scheduler.Start(() =>
- xs.Window(TimeSpan.FromTicks(70), 3, scheduler).Select((w, i) => w.Select(x => i.ToString() + " " + x.ToString())).Merge(),
- 370
- );
- res.Messages.AssertEqual(
- OnNext(205, "0 1"),
- OnNext(210, "0 2"),
- OnNext(240, "0 3"),
- OnNext(280, "1 4"),
- OnNext(320, "2 5"),
- OnNext(350, "2 6"),
- OnNext(370, "2 7")
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 370)
- );
- }
- [Fact]
- public void WindowWithTimeOrCount_Default()
- {
- Observable.Range(1, 10).Window(TimeSpan.FromDays(1), 3).Skip(1).First().SequenceEqual(Observable.Range(4, 3));
- }
- #endregion
- }
- }
|