/* Ċ Ġ* ĠMIT ĠLicense Ċ Ġ* Ċ Ġ* ĠCopyright Ġ( c ) Ġ 2 0 2 1 - 2 0 2 2 ĠPe tr us ĠN gu y á» ħ n ĠTh Ã¡ i ĠH á»įc Ċ Ġ* Ċ Ġ* ĠPermission Ġis Ġhereby Ġgranted , Ġfree Ġof Ġcharge , Ġto Ġany Ġperson Ġobtaining Ġa Ġcopy Ċ Ġ* Ġof Ġthis Ġsoftware Ġand Ġassociated Ġdocumentation Ġfiles Ġ( the Ġ" Software "), Ġto Ġdeal Ċ Ġ* Ġin Ġthe ĠSoftware Ġwithout Ġrestriction , Ġincluding Ġwithout Ġlimitation Ġthe Ġrights Ċ Ġ* Ġto Ġuse , Ġcopy , Ġmodify , Ġmerge , Ġpublish , Ġdistribute , Ġsublicense , Ġand / or Ġsell Ċ Ġ* Ġcopies Ġof Ġthe ĠSoftware , Ġand Ġto Ġpermit Ġpersons Ġto Ġwhom Ġthe ĠSoftware Ġis Ċ Ġ* Ġfurnished Ġto Ġdo Ġso , Ġsubject Ġto Ġthe Ġfollowing Ġconditions : Ċ Ġ* Ċ Ġ* ĠThe Ġabove Ġcopyright Ġnotice Ġand Ġthis Ġpermission Ġnotice Ġshall Ġbe Ġincluded Ġin Ġall Ċ Ġ* Ġcopies Ġor Ġsubstantial Ġportions Ġof Ġthe ĠSoftware . Ċ Ġ* Ċ Ġ* ĠTHE ĠSOFTWARE ĠIS ĠPROVIDED Ġ" AS ĠIS ", ĠWITHOUT ĠWARRANTY ĠOF ĠANY ĠKIND , ĠEXPRESS ĠOR Ċ Ġ* ĠIMPLIED , ĠINCLUDING ĠBUT ĠNOT ĠLIMITED ĠTO ĠTHE ĠWARRANTIES ĠOF ĠMERCHANTABILITY , Ċ Ġ* ĠFITNESS ĠFOR ĠA ĠPARTICULAR ĠPURPOSE ĠAND ĠNONINFRINGEMENT . ĠIN ĠNO ĠEVENT ĠSHALL ĠTHE Ċ Ġ* ĠAUTHORS ĠOR ĠCOPYRIGHT ĠHOLDERS ĠBE ĠLIABLE ĠFOR ĠANY ĠCLAIM , ĠDAMAGES ĠOR ĠOTHER Ċ Ġ* ĠLIABILITY , ĠWHETHER ĠIN ĠAN ĠACTION ĠOF ĠCONTRACT , ĠTORT ĠOR ĠOTHERWISE , ĠARISING ĠFROM , Ċ Ġ* ĠOUT ĠOF ĠOR ĠIN ĠCONNECTION ĠWITH ĠTHE ĠSOFTWARE ĠOR ĠTHE ĠUSE ĠOR ĠOTHER ĠDEALINGS ĠIN ĠTHE Ċ Ġ* ĠSOFTWARE . Ċ Ġ*/ Ċ Ċ package Ġcom . hoc 0 8 1 0 9 8 . flow ext Ċ Ċ import Ġkotlinx . coroutines . Cancellation Exception Ċ import Ġkotlinx . coroutines . Experimental Cor outines Api Ċ import Ġkotlinx . coroutines . Internal Cor outines Api Ċ import Ġkotlinx . coroutines . flow . flow Ċ import Ġkotlinx . coroutines . flow . flow Of Ċ import Ġkotlinx . coroutines . flow . take Ċ import Ġkotlin . test . Test Ċ import Ġkotlin . test . assertEquals Ċ import Ġkotlin . test . assertIs Ċ Ċ @ Internal Cor outines Api Ċ @ Experimental Cor outines Api Ċ class ĠMap Indexed Test Ġ: ĠBaseTest () Ġ{ ĊĠ Ġ@ Test ĊĠ Ġfun Ġbasic () Ġ= Ġrun Test Ġ{ ĊĠĠĠ Ġflow Of ( 1 , Ġ 2 , Ġ 3 , Ġ 4 ) ĊĠĠĠĠĠ Ġ. map Indexed Ġ{ Ġindex , Ġvalue Ġ-> Ġindex Ġto Ġvalue Ġ} ĊĠĠĠĠĠ Ġ. test ( ĊĠĠĠĠĠĠĠ ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 0 Ġto Ġ 1 ), ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 1 Ġto Ġ 2 ), ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 2 Ġto Ġ 3 ), ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 3 Ġto Ġ 4 ), ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Complete , ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠ Ġ) ĊĠ Ġ} ĊĊĠ Ġ@ Test ĊĠ Ġfun Ġupstream Error () Ġ= Ġrun Test Ġ{ ĊĠĠĠ Ġval Ġthrowable Ġ= ĠRuntimeException () ĊĊĠĠĠ Ġflow < Int > Ġ{ Ġthrow Ġthrowable Ġ} ĊĠĠĠĠĠ Ġ. map Indexed Ġ{ Ġindex , Ġvalue Ġ-> Ġindex Ġto Ġvalue Ġ} ĊĠĠĠĠĠ Ġ. test ( listOf ( Event . Error ( throwable ))) ĊĠ Ġ} ĊĊĠ Ġ@ Test ĊĠ Ġfun Ġcancellation () Ġ= Ġrun Test Ġ{ ĊĠĠĠ Ġflow Ġ{ ĊĠĠĠĠĠ Ġrepeat ( 5 ) Ġ{ ĊĠĠĠĠĠĠĠ Ġif Ġ( it Ġ== Ġ 2 ) Ġthrow ĠC ancellation Exception ("") ĊĠĠĠĠĠĠĠ Ġelse Ġemit ( it ) ĊĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĠĠĠĠĠ Ġ. map Indexed Ġ{ Ġindex , Ġvalue Ġ-> Ġindex Ġto Ġvalue Ġ} ĊĠĠĠĠĠ Ġ. test ( null ) Ġ{ ĊĠĠĠĠĠĠĠ ĠassertEquals ( ĊĠĠĠĠĠĠĠĠĠ ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 0 Ġto Ġ 0 ), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 1 Ġto Ġ 1 ), ĊĠĠĠĠĠĠĠĠĠ Ġ), ĊĠĠĠĠĠĠĠĠĠ Ġit . take ( 2 ) ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġassert Is < Cancellation Exception >( it . drop ( 2 ). single (). error OrThrow ()) ĊĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġflow Of ( 0 , Ġ 1 , Ġ 2 , Ġ 3 , Ġ 4 , Ġ 5 , Ġ 6 ) ĊĠĠĠĠĠ Ġ. map Indexed Ġ{ Ġindex , Ġvalue Ġ-> Ġindex Ġto Ġvalue Ġ} ĊĠĠĠĠĠ Ġ. take ( 2 ) ĊĠĠĠĠĠ Ġ. test ( ĊĠĠĠĠĠĠĠ ĠlistOf ( ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 0 Ġto Ġ 0 ), ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Value ( 1 Ġto Ġ 1 ), ĊĠĠĠĠĠĠĠĠĠ ĠEvent . Complete , ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠ Ġ) ĊĠ Ġ} Ċ } Ċ