/* Ċ Ġ* Ġ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 . reactive . flow Ċ Ċ import Ġorg . junit .* Ċ import Ġorg . reactiv est ream s . example . un icast . Async Iterable Publisher Ċ import Ġorg . reactiv est ream s . Publisher Ċ import Ġorg . reactiv est ream s . example . un icast . Infinite Increment Number Publisher Ċ import Ġorg . reactiv est ream s . t ck . Test Environment Ċ import Ġjava . util . concurrent . Executors Ċ import Ġjava . util . concurrent . ExecutorService Ċ import Ġorg . reactiv est ream s . t ck . Publisher Verification Ċ import Ġorg . testng . annotations . After Class Ċ import Ġorg . testng . annotations . BeforeClass Ċ import Ġorg . testng . annotations . Test Ċ Ċ @ Test Ċ class ĠUn bounded Integer Increment Publisher Test Ġ: ĠPublisher Verification < Int >( Test Environment ()) Ġ{ ĊĊĠĠĠ Ġprivate Ġvar Ġe : ĠExecutor Service ? Ġ= Ġnull ĊĊĠĠĠ Ġ@ BeforeClass ĊĠĠĠ Ġinternal Ġfun Ġbefore () Ġ{ ĊĠĠĠĠĠĠĠ Ġe Ġ= ĠExec utors . new Fixed ThreadPool ( 4 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ After Class ĊĠĠĠ Ġinternal Ġfun Ġafter () Ġ{ ĊĠĠĠĠĠĠĠ Ġif Ġ( e Ġ!= Ġnull ) Ġe !!. shutdown () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġcreate Publisher ( elements : ĠLong ): ĠPublisher < Int > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠIn finite Increment Number Publisher ( e !! ). as Flow (). as Publisher () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġcreate Failed Publisher (): ĠPublisher < Int > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠAsync Iterable Publisher ( object Ġ: ĠIterable < Int > Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġiterator (): ĠIterator < Int > Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġthrow ĠRuntimeException (" Error Ġstate Ġsignal !") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ}, Ġe !! ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġmax Elements From Publisher (): ĠLong Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġsuper . publisher Unable To Signal On Complete () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ 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 () Ġ{ ĊĠĠĠ Ġ} Ċ } Ċ