/* Ċ Ġ* ĠCopyright Ġ 2 0 1 8 Ġthe Ġoriginal Ġauthor Ġor Ġauthors . Ċ Ġ* Ċ Ġ* ĠLicensed Ġunder Ġthe ĠApache ĠLicense , ĠVersion Ġ 2 . 0 Ġ( the Ġ" License "); Ċ Ġ* Ġyou Ġmay Ġnot Ġuse Ġthis Ġfile Ġexcept Ġin Ġcompliance Ġwith Ġthe ĠLicense . Ċ Ġ* ĠYou Ġmay Ġobtain Ġa Ġcopy Ġof Ġthe ĠLicense Ġat Ċ Ġ* Ċ Ġ* ĠĠĠĠĠ Ġhttp :// www . apache . org / licenses / LICENSE - 2 . 0 Ċ Ġ* Ċ Ġ* ĠUnless Ġrequired Ġby Ġapplicable Ġlaw Ġor Ġagreed Ġto Ġin Ġwriting , Ġsoftware Ċ Ġ* Ġdistributed Ġunder Ġthe ĠLicense Ġis Ġdistributed Ġon Ġan Ġ" AS ĠIS " ĠBASIS , Ċ Ġ* ĠWITHOUT ĠWARRANTIES ĠOR ĠCONDITIONS ĠOF ĠANY ĠKIND , Ġeither Ġexpress Ġor Ġimplied . Ċ Ġ* ĠSee Ġthe ĠLicense Ġfor Ġthe Ġspecific Ġlanguage Ġgoverning Ġpermissions Ġand Ċ Ġ* Ġlimitations Ġunder Ġthe ĠLicense . Ċ Ġ*/ Ċ Ċ package Ġorg . gradle . kotlin . dsl . concurrent Ċ Ċ import Ġorg . gradle . kotlin . dsl . support . use To Run Ċ Ċ import Ġorg . hamcrest . Core Matchers . equalTo Ċ import Ġorg . hamcrest . Core Matchers . same Instance Ċ import Ġorg . hamcrest . Matcher Assert . assertThat Ċ Ċ import Ġorg . junit . Test Ċ Ċ import Ġjava . io . IOException Ċ Ċ import Ġjava . util . concurrent . Comp letableFuture Ċ import Ġjava . util . concurrent . Count DownLatch Ċ import Ġjava . util . concurrent . Executors Ċ import Ġjava . util . concurrent . TimeUnit ĊĊ Ċ class ĠDefault Async IO Scope Factory Test Ġ{ ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ`# io Ġfailure Ġis Ġreported Ġupon ĠIOS cope # close `() Ġ{ ĊĊĠĠĠĠĠĠĠ Ġwith Async IO Scope Factory Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġfailure Ġ= ĠIOException () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġscope Ġ= Ġnew Scope (). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġio Ġ{ Ġthrow Ġfailure Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrun Catch ing Ġ{ Ġscope . close () Ġ}. exception OrNull (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsame Instance < Throwable >( failure ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ`# io Ġfailure Ġis Ġreported Ġupon Ġnext Ġ# io Ġcall `() Ġ{ ĊĊĠĠĠĠĠĠĠ Ġwith Async IO Scope Factory Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġexpected Failure Ġ= ĠIOException () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġfailure Latch Ġ= ĠFailure Latch () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġscope Ġ= Ġnew Scope (). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġio Ġ{ Ġfailure Latch . fail With ( expected Failure ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfailure Latch . await () ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġrun Catch ing Ġ{ Ġscope . io Ġ{ Ġ} Ġ}. exception OrNull (), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsame Instance < Throwable >( expected Failure ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` IO Scope Ġfailures Ġare Ġisolated `() Ġ{ ĊĊĠĠĠĠĠĠĠ Ġwith Async IO Scope Factory Ġ{ ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġgiven : Ġa Ġfailure Ġin Ġone Ġscope ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġfailure Latch Ġ= ĠFailure Latch () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġnew Scope (). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġio Ġ{ Ġfailure Latch . fail With ( IllegalStateException ()) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġfailure Latch . await () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġthen : Ġactions Ġcan Ġstill Ġbe Ġscheduled Ġin Ġseparate Ġscope ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġisolated Scope Action Ġ= ĠCompletableFuture < Unit >() ĊĠĠĠĠĠĠĠĠĠĠĠ Ġnew Scope (). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġio Ġ{ Ġisolated Scope Action . complete ( Unit ) Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġisolated Scope Action . get ( 5 0 , ĠTimeUnit . MILLISECONDS ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠequalTo ( Unit ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate ĊĠĠĠ Ġclass ĠFailure Latch Ġ{ ĊĊĠĠĠĠĠĠĠ Ġprivate ĊĠĠĠĠĠĠĠ Ġval Ġl atch : ĠCount DownLatch Ġ= ĠCount DownLatch ( 1 ) ĊĊĠĠĠĠĠĠĠ Ġfun Ġfail With ( failure : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġl atch . count Down () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow Ġfailure ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġfun Ġawait () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// ĠThere 's Ġsmall Ġchance Ġthis Ġthread Ġcan Ġbe Ġaw aken ed Ġbefore ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġthe Ġexception Ġin Ġthe ĠIO Ġthread Ġis Ġcaught , Ġso Ġlet 's Ġsleep Ġa Ġlittle ĊĠĠĠĠĠĠĠĠĠĠĠ Ġl atch . await ( 1 , ĠTimeUnit . SECONDS ) ĊĠĠĠĠĠĠĠĠĠĠĠ ĠThread . sleep ( 1 ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate ĊĠĠĠ Ġfun Ġwith Async IO Scope Factory ( action : ĠDefault Async IO Scope Factory . () Ġ-> ĠUnit ) Ġ{ ĊĠĠĠĠĠĠĠ ĠDefault Async IO Scope Factory Ġ{ ĠExec utors . new Single Thread Executor () Ġ}. use To Run ( action ) ĊĠĠĠ Ġ} Ċ } Ċ