runAsync.txt

"nioEventLoopGroup-2-31" #137 prio=10 os_prio=0 tid=0x00007f3a74022000 nid=0x2d15 runnable [0x00007f3a708f3000]
   java.lang.Thread.State: RUNNABLE
        at sun.misc.Unsafe.unpark(Native Method)
        at java.util.concurrent.ForkJoinPool.signalWork(ForkJoinPool.java:1649)
        at java.util.concurrent.ForkJoinPool.externalPush(ForkJoinPool.java:2414)
        at java.util.concurrent.ForkJoinPool.execute(ForkJoinPool.java:2630)
        at scala.concurrent.impl.ExecutionContextImpl$$anon$3.execute(ExecutionContextImpl.scala:131)
        at scala.concurrent.impl.ExecutionContextImpl.execute(ExecutionContextImpl.scala:20)
        at cats.effect.internals.IOShift$$anon$1.apply(IOShift.scala:28)
        at cats.effect.internals.IOShift$$anon$1.apply(IOShift.scala:26)
        at cats.effect.internals.IORunLoop$RestartCallback.start(IORunLoop.scala:337)
        at cats.effect.internals.IORunLoop$.cats$effect$internals$IORunLoop$$loop(IORunLoop.scala:119)
        at cats.effect.internals.IORunLoop$.startCancelable(IORunLoop.scala:41)
        at cats.effect.internals.IOStart$.$anonfun$apply$1(IOStart.scala:35)
        at cats.effect.internals.IOStart$.$anonfun$apply$1$adapted(IOStart.scala:28)
        at cats.effect.internals.IOStart$$$Lambda$32/447212746.apply(Unknown Source)
        at cats.effect.internals.IORunLoop$RestartCallback.start(IORunLoop.scala:337)
        at cats.effect.internals.IORunLoop$.cats$effect$internals$IORunLoop$$loop(IORunLoop.scala:119)
        at cats.effect.internals.IORunLoop$.start(IORunLoop.scala:34)
        at cats.effect.IO.unsafeRunAsync(IO.scala:258)
        at cats.effect.IO.$anonfun$runAsync$1(IO.scala:178)
        at cats.effect.IO$$Lambda$409/1499817796.apply$mcV$sp(Unknown Source)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
        at cats.effect.internals.IORunLoop$.step(IORunLoop.scala:185)
        at cats.effect.IO.unsafeRunTimed(IO.scala:321)
        at cats.effect.IO.unsafeRunSync(IO.scala:240)
        at cats.effect.SyncIO.unsafeRunSync(SyncIO.scala:48)
        at quasar.physical.mongo.Mongo.quasar$physical$mongo$Mongo$$run$1(Mongo.scala:55)
        at quasar.physical.mongo.Mongo.$anonfun$observableAsStream$4(Mongo.scala:81)
        at quasar.physical.mongo.Mongo.$anonfun$observableAsStream$4$adapted(Mongo.scala:81)
        at quasar.physical.mongo.Mongo$$Lambda$2605/1399943465.apply(Unknown Source)
        at quasar.physical.mongo.Mongo$$anon$1.onNext(Mongo.scala:65)
        at com.mongodb.async.client.AbstractSubscription.onNext(AbstractSubscription.java:135)
        at com.mongodb.async.client.AbstractSubscription.processResultsQueue(AbstractSubscription.java:203)
        at com.mongodb.async.client.AbstractSubscription.tryProcessResultsQueue(AbstractSubscription.java:159)
        at com.mongodb.async.client.MongoIterableSubscription$2.onResult(MongoIterableSubscription.java:101)