1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377537853795380538153825383538453855386538753885389539053915392539353945395539653975398539954005401540254035404540554065407540854095410541154125413541454155416541754185419542054215422542354245425542654275428542954305431543254335434543554365437543854395440544154425443544454455446544754485449545054515452545354545455545654575458545954605461546254635464546554665467546854695470547154725473547454755476547754785479548054815482548354845485548654875488548954905491549254935494549554965497549854995500550155025503550455055506550755085509551055115512551355145515551655175518551955205521552255235524552555265527552855295530553155325533553455355536553755385539554055415542554355445545554655475548554955505551555255535554555555565557555855595560556155625563556455655566556755685569557055715572557355745575557655775578557955805581558255835584558555865587558855895590559155925593559455955596559755985599560056015602560356045605560656075608560956105611561256135614561556165617561856195620562156225623562456255626562756285629563056315632563356345635563656375638563956405641564256435644564556465647564856495650565156525653565456555656565756585659566056615662566356645665566656675668566956705671567256735674567556765677567856795680568156825683568456855686568756885689569056915692569356945695569656975698569957005701570257035704570557065707570857095710571157125713571457155716571757185719572057215722572357245725572657275728572957305731573257335734573557365737573857395740574157425743574457455746574757485749575057515752575357545755575657575758575957605761576257635764576557665767576857695770577157725773577457755776577757785779578057815782578357845785578657875788578957905791579257935794579557965797579857995800580158025803580458055806580758085809581058115812581358145815581658175818581958205821582258235824582558265827582858295830583158325833583458355836583758385839584058415842584358445845584658475848584958505851585258535854585558565857585858595860586158625863586458655866586758685869587058715872587358745875587658775878587958805881588258835884588558865887588858895890589158925893589458955896589758985899590059015902590359045905590659075908590959105911591259135914591559165917591859195920592159225923592459255926592759285929593059315932593359345935593659375938593959405941594259435944594559465947594859495950595159525953595459555956595759585959596059615962596359645965596659675968596959705971597259735974597559765977597859795980598159825983598459855986598759885989599059915992599359945995599659975998599960006001600260036004600560066007600860096010601160126013601460156016601760186019602060216022602360246025602660276028602960306031603260336034603560366037603860396040604160426043604460456046604760486049605060516052605360546055605660576058605960606061606260636064606560666067606860696070607160726073607460756076607760786079608060816082608360846085608660876088608960906091609260936094609560966097609860996100610161026103610461056106610761086109611061116112611361146115611661176118611961206121612261236124612561266127612861296130613161326133613461356136613761386139614061416142614361446145614661476148614961506151615261536154615561566157615861596160616161626163616461656166616761686169617061716172617361746175617661776178617961806181618261836184618561866187618861896190619161926193619461956196619761986199620062016202620362046205620662076208620962106211621262136214621562166217621862196220622162226223622462256226622762286229623062316232623362346235623662376238623962406241624262436244624562466247624862496250625162526253625462556256625762586259626062616262626362646265626662676268626962706271627262736274627562766277627862796280628162826283628462856286628762886289629062916292629362946295629662976298629963006301630263036304630563066307630863096310631163126313631463156316631763186319632063216322632363246325632663276328632963306331633263336334633563366337633863396340634163426343634463456346634763486349635063516352635363546355635663576358635963606361636263636364636563666367636863696370637163726373637463756376637763786379638063816382638363846385638663876388638963906391639263936394639563966397639863996400640164026403640464056406640764086409641064116412641364146415641664176418641964206421642264236424642564266427642864296430643164326433643464356436643764386439644064416442644364446445644664476448644964506451645264536454645564566457645864596460646164626463646464656466646764686469647064716472647364746475647664776478647964806481648264836484648564866487648864896490649164926493649464956496649764986499650065016502650365046505650665076508650965106511651265136514651565166517651865196520652165226523652465256526652765286529653065316532653365346535653665376538653965406541654265436544654565466547654865496550655165526553655465556556655765586559656065616562656365646565656665676568656965706571657265736574657565766577657865796580658165826583658465856586658765886589659065916592659365946595659665976598659966006601660266036604660566066607660866096610661166126613661466156616661766186619662066216622662366246625662666276628662966306631663266336634663566366637663866396640664166426643664466456646664766486649665066516652665366546655665666576658665966606661666266636664666566666667666866696670667166726673667466756676667766786679668066816682668366846685668666876688668966906691669266936694669566966697669866996700670167026703670467056706670767086709671067116712671367146715671667176718671967206721672267236724672567266727672867296730673167326733673467356736673767386739674067416742674367446745674667476748674967506751675267536754675567566757675867596760676167626763676467656766676767686769677067716772677367746775677667776778677967806781678267836784678567866787678867896790679167926793679467956796679767986799680068016802680368046805680668076808680968106811681268136814681568166817681868196820682168226823682468256826682768286829683068316832683368346835683668376838683968406841684268436844684568466847684868496850685168526853685468556856685768586859686068616862686368646865686668676868686968706871687268736874687568766877687868796880688168826883688468856886688768886889689068916892689368946895689668976898689969006901690269036904690569066907690869096910691169126913691469156916691769186919692069216922692369246925692669276928692969306931693269336934693569366937693869396940694169426943694469456946694769486949695069516952695369546955695669576958695969606961696269636964696569666967696869696970697169726973697469756976697769786979698069816982698369846985698669876988698969906991699269936994699569966997699869997000700170027003700470057006700770087009701070117012701370147015701670177018701970207021702270237024702570267027702870297030703170327033703470357036703770387039704070417042704370447045704670477048704970507051705270537054705570567057705870597060706170627063706470657066706770687069707070717072707370747075707670777078707970807081708270837084708570867087708870897090709170927093709470957096709770987099710071017102710371047105710671077108710971107111711271137114711571167117711871197120712171227123712471257126712771287129713071317132713371347135713671377138713971407141714271437144714571467147714871497150715171527153715471557156715771587159716071617162716371647165716671677168716971707171717271737174717571767177717871797180718171827183718471857186718771887189719071917192719371947195719671977198719972007201720272037204720572067207720872097210721172127213721472157216721772187219722072217222722372247225722672277228722972307231723272337234723572367237723872397240724172427243724472457246724772487249725072517252725372547255725672577258725972607261726272637264726572667267726872697270727172727273727472757276727772787279728072817282728372847285728672877288728972907291729272937294729572967297729872997300730173027303730473057306730773087309731073117312731373147315731673177318731973207321732273237324732573267327732873297330733173327333733473357336733773387339734073417342734373447345734673477348734973507351735273537354735573567357735873597360736173627363736473657366736773687369737073717372737373747375737673777378737973807381738273837384738573867387738873897390739173927393739473957396739773987399740074017402740374047405740674077408740974107411741274137414741574167417741874197420742174227423742474257426742774287429743074317432743374347435743674377438743974407441744274437444744574467447744874497450745174527453745474557456745774587459746074617462746374647465746674677468746974707471747274737474747574767477747874797480748174827483748474857486748774887489749074917492749374947495749674977498749975007501750275037504750575067507750875097510751175127513751475157516751775187519752075217522752375247525752675277528752975307531753275337534753575367537753875397540754175427543754475457546754775487549755075517552755375547555755675577558755975607561756275637564756575667567756875697570757175727573757475757576757775787579758075817582758375847585758675877588758975907591759275937594759575967597759875997600760176027603760476057606760776087609761076117612761376147615761676177618761976207621762276237624762576267627762876297630763176327633763476357636763776387639764076417642764376447645764676477648764976507651765276537654765576567657765876597660766176627663766476657666766776687669767076717672767376747675767676777678767976807681768276837684768576867687768876897690769176927693769476957696769776987699770077017702770377047705770677077708770977107711771277137714771577167717771877197720772177227723772477257726772777287729773077317732773377347735773677377738773977407741774277437744774577467747774877497750775177527753775477557756775777587759776077617762776377647765776677677768776977707771777277737774777577767777777877797780778177827783778477857786778777887789779077917792779377947795779677977798779978007801780278037804780578067807780878097810781178127813781478157816781778187819782078217822782378247825782678277828782978307831783278337834783578367837783878397840784178427843784478457846784778487849785078517852785378547855785678577858785978607861786278637864786578667867786878697870787178727873787478757876787778787879788078817882788378847885788678877888788978907891789278937894789578967897789878997900790179027903790479057906790779087909791079117912791379147915791679177918791979207921792279237924792579267927792879297930793179327933793479357936793779387939794079417942794379447945794679477948794979507951795279537954795579567957795879597960796179627963796479657966796779687969797079717972797379747975797679777978797979807981798279837984798579867987798879897990799179927993799479957996799779987999800080018002800380048005800680078008800980108011801280138014801580168017801880198020802180228023802480258026802780288029803080318032803380348035803680378038803980408041804280438044804580468047804880498050805180528053805480558056805780588059806080618062806380648065806680678068806980708071807280738074807580768077807880798080808180828083808480858086808780888089809080918092809380948095809680978098809981008101810281038104810581068107810881098110811181128113811481158116811781188119812081218122812381248125812681278128812981308131813281338134813581368137813881398140814181428143814481458146814781488149815081518152815381548155815681578158815981608161816281638164816581668167816881698170817181728173817481758176817781788179818081818182818381848185818681878188818981908191819281938194819581968197819881998200820182028203820482058206820782088209821082118212821382148215821682178218821982208221822282238224822582268227822882298230823182328233823482358236823782388239824082418242824382448245824682478248824982508251825282538254825582568257825882598260826182628263826482658266826782688269827082718272827382748275827682778278827982808281828282838284828582868287828882898290829182928293829482958296829782988299830083018302830383048305830683078308830983108311831283138314831583168317831883198320832183228323832483258326832783288329833083318332833383348335833683378338833983408341834283438344834583468347834883498350835183528353835483558356835783588359836083618362836383648365836683678368836983708371837283738374837583768377837883798380838183828383838483858386838783888389839083918392839383948395839683978398839984008401840284038404840584068407840884098410841184128413841484158416841784188419842084218422842384248425842684278428842984308431843284338434843584368437843884398440844184428443844484458446844784488449845084518452845384548455845684578458845984608461846284638464846584668467846884698470847184728473847484758476847784788479848084818482848384848485848684878488848984908491849284938494849584968497849884998500850185028503850485058506850785088509851085118512851385148515851685178518851985208521852285238524852585268527852885298530853185328533853485358536853785388539854085418542854385448545854685478548854985508551855285538554855585568557855885598560856185628563856485658566856785688569857085718572857385748575857685778578857985808581858285838584858585868587858885898590859185928593859485958596859785988599860086018602860386048605860686078608860986108611861286138614861586168617861886198620862186228623862486258626862786288629863086318632863386348635863686378638863986408641864286438644864586468647864886498650865186528653865486558656865786588659866086618662866386648665866686678668866986708671867286738674867586768677867886798680868186828683868486858686868786888689869086918692869386948695869686978698869987008701870287038704870587068707870887098710871187128713871487158716871787188719872087218722872387248725872687278728872987308731873287338734873587368737873887398740874187428743874487458746874787488749875087518752875387548755875687578758875987608761876287638764876587668767876887698770877187728773877487758776877787788779878087818782878387848785878687878788878987908791879287938794879587968797879887998800880188028803880488058806880788088809881088118812881388148815881688178818881988208821882288238824882588268827882888298830883188328833883488358836883788388839884088418842884388448845884688478848884988508851885288538854885588568857885888598860886188628863886488658866886788688869887088718872887388748875887688778878887988808881888288838884888588868887888888898890889188928893889488958896889788988899890089018902890389048905890689078908890989108911891289138914891589168917891889198920892189228923892489258926892789288929893089318932893389348935893689378938893989408941894289438944894589468947894889498950895189528953895489558956895789588959896089618962896389648965896689678968896989708971897289738974897589768977897889798980898189828983898489858986898789888989899089918992899389948995899689978998899990009001900290039004900590069007900890099010901190129013901490159016901790189019902090219022902390249025902690279028902990309031903290339034903590369037903890399040904190429043904490459046904790489049905090519052905390549055 |
- // Licensed to the .NET Foundation under one or more agreements.
- // The .NET Foundation licenses this file to you under the Apache 2.0 License.
- // See the LICENSE file in the project root for more 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_completes_first()
- {
- var scheduler = new TestScheduler();
- var xs = scheduler.CreateHotObservable(
- OnNext(150, 1),
- OnNext(220, 2),
- OnNext(240, 3),
- OnNext(290, 4),
- OnCompleted<int>(600)
- );
- 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>(600 /* on sampling boundaries only */)
- );
- xs.Subscriptions.AssertEqual(
- Subscribe(200, 600)
- );
- ys.Subscriptions.AssertEqual(
- Subscribe(200, 500)
- );
- }
- [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
- }
- }
|