Gopal S Akshintala
02/26/2020, 12:35 PMfun main() {
val reactorDao = object : NonBlockingReactorRepo<ForMonoK>, Async<ForMonoK> by MonoK.async() {
override val libDBClient = ReactorLibDBClient()
}
val nonBlockingGet = reactorDao.getIt().fix().mono
val blockingDao = object : BlockingRepo<ForIO>, Async<ForIO> by IO.async() {
override val libDBClient = BlockingLibDBClient()
}
val blockingGet = blockingDao.getIt().fix().unsafeRunSync()
}
fun <F> RepoTC<F>.getIt(): Kind<F, String> = get()