/* Ċ Ġ* ĠCopyright Ġ 2 0 1 6 - 2 0 1 9 ĠJetBrains Ġs . r . o . ĠUse Ġof Ġthis Ġsource Ġcode Ġis Ġgoverned Ġby Ġthe ĠApache Ġ 2 . 0 Ġlicense . Ċ Ġ*/ Ċ Ċ package Ġkotlinx . coroutines . rx 3 Ċ Ċ import Ġio . reactivex . rx java 3 . core .* Ċ import Ġkotlinx . coroutines . flow .* Ċ import Ġorg . junit .* Ċ import Ġorg . reactiv est ream s .* Ċ import Ġorg . reactiv est ream s . t ck .* Ċ Ċ class ĠIterable Flow As Flow able T ck Test Ġ: ĠPublisher Verification < Long >( Test Environment ()) Ġ{ ĊĊĠĠĠ Ġprivate Ġfun Ġgenerate ( num : ĠLong ): ĠArray < Long > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠArray ( if Ġ( num Ġ>= ĠInteger . MAX _ VALUE ) Ġ 1 0 0 0 0 0 0 Ġelse Ġnum . toInt ()) Ġ{ Ġit . to Long () Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġcreate Publisher ( elements : ĠLong ): ĠFlow able < Long > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġgenerate ( elements ). as Iterable (). as Flow (). as Flow able () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġcreate Failed Publisher (): ĠPublisher < Long >? Ġ= Ġnull ĊĊĠĠĠ Ġ@ Ignore ĊĠĠĠ Ġoverride Ġfun Ġrequired _ spec 3 0 9 _ request Zero Must Signal IllegalArgumentException () Ġ{ ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Ignore ĊĠĠĠ Ġoverride Ġfun Ġrequired _ spec 3 0 9 _ request Negative Number Must Signal IllegalArgumentException () Ġ{ ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Ignore ĊĠĠĠ Ġoverride Ġfun Ġrequired _ spec 3 1 2 _ cancel Must Make The Publisher To Event ually Stop Signal ing () Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĊĠĠĠ Ġ} Ċ } Ċ