Skip to content

Instantly share code, notes, and snippets.

@Odomontois
Last active December 22, 2017 10:17
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Odomontois/c7cf55d86ee6d5923e5ad266ed9fc872 to your computer and use it in GitHub Desktop.
Save Odomontois/c7cf55d86ee6d5923e5ad266ed9fc872 to your computer and use it in GitHub Desktop.
MVar example

We have some mutable mapping of languages to count of likes. Lof ot users, each represented with LanguageLover, each with one favorite language are trying independently of each other follow this logic: Read current like count for favorite language and all others. If the favorite language is not the most beloved one in the moment, add likes until it be.

import akka.util.Timeout
import cats.syntax.apply._
import monix.eval.{MVar, Task}
import monix.execution.Scheduler.Implicits._
import scala.concurrent.duration._
import scala.concurrent.{Await, Future}
import scala.language.{higherKinds, postfixOps}
object LanguageStore {
val userCount = 10
val likeCount = 1000
implicit val timeout: Timeout = Timeout(1 seconds)
def main(args: Array[String]): Unit = {
Await.result(test(LanguageLover.manyUsers(userCount, likeCount).runAsync), Duration.Inf)
}
def test[A](calc: => Future[A]): Future[A] = {
val start = System.nanoTime()
calc.map { x =>
println(x)
println((System.nanoTime() - start) / 1000000.0)
x
}
}
}
class LanguageStore {
private[this] var likes = MVar(LanguageLover.nameMap)
def put(name: String, count: Long): Task[Unit] =
likes.take.flatMap(l => likes.put(l + (name -> count)))
def get(name: String): Task[Long] = likes.read.map(_ (name))
def getAll: Task[Map[String, Long]] = likes.read
}
class LanguageLover(name: String)(store: LanguageStore) {
def bump: Task[Unit] =
Task.traverse(LanguageLover.names)(name => store.get(name).map(name -> _)).flatMap { results =>
val (List((_, count)), others) = results.partition(_._1 == name)
val best = others.map(_._2).max
if (count > best) Task.unit else store.put(name, best + 1)
}
def bumps(n: Int): Task[Unit] = if (n == 0) Task.unit else bump *> Task.defer(bumps(n - 1))
}
object LanguageLover {
val names = List("haskell", "scala", "clojure", "elixir")
val nameMap = names.map(_ -> 0L).toMap
def manyUsers(n: Int, k: Int) = {
val store = new LanguageStore
Task.gather((1 to k)
.flatMap(_ => LanguageLover.names)
.map(name => new LanguageLover(name)(store).bumps(n))) *>
store.getAll
}
}
/usr/lib/jvm/java-1.8.0-openjdk-amd64/bin/java -Xss2048k -javaagent:/home/odomontois/.local/share/JetBrains/Toolbox/apps/IDEA-C/ch-0/173.4127.17/lib/idea_rt.jar=39959:/home/odomontois/.local/share/JetBrains/Toolbox/apps/IDEA-C/ch-0/173.4127.17/bin -Dfile.encoding=UTF-8 -classpath /usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/charsets.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/cldrdata.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/icedtea-sound.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/jaccess.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/jce.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/jsse.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/management-agent.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/resources.jar:/usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/lib/rt.jar:/home/odomontois/Prog/projects/scala/akka-sandbox/target/scala-2.12/test-classes:/home/odomontois/Prog/projects/scala/akka-sandbox/target/scala-2.12/classes:/home/odomontois/.ivy2/cache/com.beachape/enumeratum-macros_2.12/jars/enumeratum-macros_2.12-1.5.2.jar:/home/odomontois/.ivy2/cache/com.beachape/enumeratum_2.12/jars/enumeratum_2.12-1.5.2.jar:/home/odomontois/.ivy2/cache/com.chuusai/shapeless_2.12/bundles/shapeless_2.12-2.3.2.jar:/home/odomontois/.ivy2/cache/com.fasterxml.jackson.core/jackson-annotations/bundles/jackson-annotations-2.8.4.jar:/home/odomontois/.ivy2/cache/com.fasterxml.jackson.core/jackson-core/bundles/jackson-core-2.8.4.jar:/home/odomontois/.ivy2/cache/com.fasterxml.jackson.core/jackson-databind/bundles/jackson-databind-2.8.4.jar:/home/odomontois/.ivy2/cache/com.fasterxml.jackson.module/jackson-module-paranamer/bundles/jackson-module-paranamer-2.8.4.jar:/home/odomontois/.ivy2/cache/com.fasterxml.jackson.module/jackson-module-scala_2.12/bundles/jackson-module-scala_2.12-2.8.4.jar:/home/odomontois/.ivy2/cache/com.github.fomkin/pushka-core_2.12/jars/pushka-core_2.12-0.8.0.jar:/home/odomontois/.ivy2/cache/com.github.fomkin/pushka-json_2.12/jars/pushka-json_2.12-0.8.0.jar:/home/odomontois/.ivy2/cache/com.github.julien-truffaut/monocle-core_2.12/jars/monocle-core_2.12-1.5.0-cats-M1.jar:/home/odomontois/.ivy2/cache/com.github.julien-truffaut/monocle-generic_2.12/jars/monocle-generic_2.12-1.5.0-cats-M1.jar:/home/odomontois/.ivy2/cache/com.github.julien-truffaut/monocle-macro_2.12/jars/monocle-macro_2.12-1.5.0-cats-M1.jar:/home/odomontois/.ivy2/cache/com.github.julien-truffaut/newts-core_2.12/jars/newts-core_2.12-0.3.0-MF-2.jar:/home/odomontois/.ivy2/cache/com.github.mpilquist/simulacrum_2.12/jars/simulacrum_2.12-0.11.0.jar:/home/odomontois/.ivy2/cache/com.github.nscala-time/nscala-time_2.12.0-RC1/jars/nscala-time_2.12.0-RC1-2.14.0.jar:/home/odomontois/.ivy2/cache/com.google.code.findbugs/jsr305/jars/jsr305-1.3.9.jar:/home/odomontois/.ivy2/cache/com.google.errorprone/error_prone_annotations/jars/error_prone_annotations-2.0.18.jar:/home/odomontois/.ivy2/cache/com.google.guava/guava/bundles/guava-23.5-jre.jar:/home/odomontois/.ivy2/cache/com.google.j2objc/j2objc-annotations/jars/j2objc-annotations-1.1.jar:/home/odomontois/.ivy2/cache/com.google.protobuf/protobuf-java/bundles/protobuf-java-3.2.0.jar:/home/odomontois/.ivy2/cache/com.kailuowang/mainecoon-core_2.12/jars/mainecoon-core_2.12-0.5.0.jar:/home/odomontois/.ivy2/cache/com.lihaoyi/fastparse-utils_2.12/jars/fastparse-utils_2.12-0.4.3.jar:/home/odomontois/.ivy2/cache/com.lihaoyi/fastparse_2.12/jars/fastparse_2.12-0.4.3.jar:/home/odomontois/.ivy2/cache/com.lihaoyi/sourcecode_2.12/jars/sourcecode_2.12-0.1.3.jar:/home/odomontois/.ivy2/cache/com.storm-enroute/scalameter-core_2.12/jars/scalameter-core_2.12-0.8.2.jar:/home/odomontois/.ivy2/cache/com.storm-enroute/scalameter_2.12/jars/scalameter_2.12-0.8.2.jar:/home/odomontois/.ivy2/cache/com.thoughtworks.paranamer/paranamer/bundles/paranamer-2.8.jar:/home/odomontois/.ivy2/cache/com.trueaccord.lenses/lenses_2.12/jars/lenses_2.12-0.4.10.jar:/home/odomontois/.ivy2/cache/com.trueaccord.scalapb/scalapb-runtime_2.12/jars/scalapb-runtime_2.12-0.6.0-pre2.jar:/home/odomontois/.ivy2/cache/com.typesafe/config/bundles/config-1.3.2.jar:/home/odomontois/.ivy2/cache/com.typesafe/ssl-config-core_2.12/bundles/ssl-config-core_2.12-0.2.2.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-actor_2.12/jars/akka-actor_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-agent_2.12/jars/akka-agent_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-cluster-tools_2.12/jars/akka-cluster-tools_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-cluster_2.12/jars/akka-cluster_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-http-core_2.12/jars/akka-http-core_2.12-10.0.6.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-http_2.12/jars/akka-http_2.12-10.0.6.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-parsing_2.12/jars/akka-parsing_2.12-10.0.6.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-protobuf_2.12/jars/akka-protobuf_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-remote_2.12/jars/akka-remote_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-slf4j_2.12/jars/akka-slf4j_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-stream_2.12/jars/akka-stream_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-testkit_2.12/jars/akka-testkit_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.akka/akka-typed_2.12/jars/akka-typed_2.12-2.5.8.jar:/home/odomontois/.ivy2/cache/com.typesafe.slick/slick-hikaricp_2.12/bundles/slick-hikaricp_2.12-3.2.0.jar:/home/odomontois/.ivy2/cache/com.typesafe.slick/slick_2.12/bundles/slick_2.12-3.2.0.jar:/home/odomontois/.ivy2/cache/com.zaxxer/HikariCP/bundles/HikariCP-2.5.1.jar:/home/odomontois/.ivy2/cache/commons-io/commons-io/jars/commons-io-2.4.jar:/home/odomontois/.ivy2/cache/de.heikoseeberger/akka-http-circe_2.12/jars/akka-http-circe_2.12-1.16.1.jar:/home/odomontois/.ivy2/cache/io.aeron/aeron-client/jars/aeron-client-1.3.0.jar:/home/odomontois/.ivy2/cache/io.aeron/aeron-driver/jars/aeron-driver-1.3.0.jar:/home/odomontois/.ivy2/cache/io.circe/circe-core_2.12/jars/circe-core_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-derivation_2.12/jars/circe-derivation_2.12-0.8.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-generic-extras_2.12/jars/circe-generic-extras_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-generic_2.12/jars/circe-generic_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-java8_2.12/jars/circe-java8_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-jawn_2.12/jars/circe-jawn_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-numbers_2.12/jars/circe-numbers_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-parser_2.12/jars/circe-parser_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.circe/circe-shapes_2.12/jars/circe-shapes_2.12-0.9.0-M2.jar:/home/odomontois/.ivy2/cache/io.frees/frees-async-cats-effect_2.12/jars/frees-async-cats-effect_2.12-0.4.6.jar:/home/odomontois/.ivy2/cache/io.frees/frees-async_2.12/jars/frees-async_2.12-0.4.6.jar:/home/odomontois/.ivy2/cache/io.frees/frees-core_2.12/jars/frees-core_2.12-0.4.6.jar:/home/odomontois/.ivy2/cache/io.frees/frees-effects_2.12/jars/frees-effects_2.12-0.4.6.jar:/home/odomontois/.ivy2/cache/io.frees/frees-tagless_2.12/jars/frees-tagless_2.12-0.4.6.jar:/home/odomontois/.ivy2/cache/io.frees/iota-core_2.12/jars/iota-core_2.12-0.3.3.jar:/home/odomontois/.ivy2/cache/io.iteratee/iteratee-core_2.12/jars/iteratee-core_2.12-0.15.0.jar:/home/odomontois/.ivy2/cache/io.monix/monix-eval_2.12/jars/monix-eval_2.12-3.0.0-M2.jar:/home/odomontois/.ivy2/cache/io.monix/monix-execution_2.12/jars/monix-execution_2.12-3.0.0-M2.jar:/home/odomontois/.ivy2/cache/io.monix/monix-reactive_2.12/jars/monix-reactive_2.12-3.0.0-M2.jar:/home/odomontois/.ivy2/cache/io.monix/monix-tail_2.12/jars/monix-tail_2.12-3.0.0-M2.jar:/home/odomontois/.ivy2/cache/io.monix/monix_2.12/jars/monix_2.12-3.0.0-M2.jar:/home/odomontois/.ivy2/cache/io.netty/netty/bundles/netty-3.10.6.Final.jar:/home/odomontois/.ivy2/cache/io.spray/spray-json_2.12/bundles/spray-json_2.12-1.3.2.jar:/home/odomontois/.ivy2/cache/joda-time/joda-time/jars/joda-time-2.9.4.jar:/home/odomontois/.ivy2/cache/org.agrona/agrona/jars/agrona-0.9.6.jar:/home/odomontois/.ivy2/cache/org.apache.commons/commons-lang3/jars/commons-lang3-3.4.jar:/home/odomontois/.ivy2/cache/org.apache.commons/commons-math3/jars/commons-math3-3.2.jar:/home/odomontois/.ivy2/cache/org.checkerframework/checker-qual/jars/checker-qual-2.0.0.jar:/home/odomontois/.ivy2/cache/org.codehaus.mojo/animal-sniffer-annotations/jars/animal-sniffer-annotations-1.14.jar:/home/odomontois/.ivy2/cache/org.jctools/jctools-core/bundles/jctools-core-2.0.2.jar:/home/odomontois/.ivy2/cache/org.joda/joda-convert/jars/joda-convert-1.2.jar:/home/odomontois/.ivy2/cache/org.mongodb/casbah-commons_2.12.0-RC1/jars/casbah-commons_2.12.0-RC1-3.1.1.jar:/home/odomontois/.ivy2/cache/org.mongodb/casbah-core_2.12.0-RC1/jars/casbah-core_2.12.0-RC1-3.1.1.jar:/home/odomontois/.ivy2/cache/org.mongodb/casbah-gridfs_2.12.0-RC1/jars/casbah-gridfs_2.12.0-RC1-3.1.1.jar:/home/odomontois/.ivy2/cache/org.mongodb/casbah-query_2.12.0-RC1/jars/casbah-query_2.12.0-RC1-3.1.1.jar:/home/odomontois/.ivy2/cache/org.mongodb/mongo-java-driver/jars/mongo-java-driver-3.2.2.jar:/home/odomontois/.ivy2/cache/org.ow2.asm/asm/jars/asm-5.0.4.jar:/home/odomontois/.ivy2/cache/org.reactivestreams/reactive-streams/jars/reactive-streams-1.0.1.jar:/home/odomontois/.ivy2/cache/org.scala-lang.modules/scala-java8-compat_2.12/bundles/scala-java8-compat_2.12-0.8.0.jar:/home/odomontois/.ivy2/cache/org.scala-lang.modules/scala-parser-combinators_2.12/bundles/scala-parser-combinators_2.12-1.0.4.jar:/home/odomontois/.ivy2/cache/org.scala-lang.modules/scala-xml_2.12/bundles/scala-xml_2.12-1.0.6.jar:/home/odomontois/.ivy2/cache/org.scala-sbt/test-interface/jars/test-interface-1.0.jar:/home/odomontois/.ivy2/cache/org.scala-stm/scala-stm_2.12/jars/scala-stm_2.12-0.8.jar:/home/odomontois/.ivy2/cache/org.scala-tools.testing/test-interface/jars/test-interface-0.5.jar:/home/odomontois/.ivy2/cache/org.scalacheck/scalacheck_2.12/jars/scalacheck_2.12-1.13.4.jar:/home/odomontois/.ivy2/cache/org.scalameta/common_2.12/jars/common_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/dialects_2.12/jars/dialects_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/inline_2.12/jars/inline_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/inputs_2.12/jars/inputs_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/io_2.12/jars/io_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/parsers_2.12/jars/parsers_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/quasiquotes_2.12/jars/quasiquotes_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/scalameta_2.12/jars/scalameta_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/semantic_2.12/jars/semantic_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/tokenizers_2.12/jars/tokenizers_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/tokens_2.12/jars/tokens_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/transversers_2.12/jars/transversers_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalameta/trees_2.12/jars/trees_2.12-1.8.0.jar:/home/odomontois/.ivy2/cache/org.scalaz/scalaz-core_2.12/bundles/scalaz-core_2.12-7.3.0-M14.jar:/home/odomontois/.ivy2/cache/org.scalaz/scalaz-effect_2.12/bundles/scalaz-effect_2.12-7.3.0-M14.jar:/home/odomontois/.ivy2/cache/org.slf4j/slf4j-api/jars/slf4j-api-1.7.25.jar:/home/odomontois/.ivy2/cache/org.slf4j/slf4j-nop/jars/slf4j-nop-1.6.4.jar:/home/odomontois/.ivy2/cache/org.spire-math/jawn-parser_2.12/jars/jawn-parser_2.12-0.11.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/algebra_2.12/jars/algebra_2.12-0.7.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/alleycats-core_2.12/jars/alleycats-core_2.12-0.1.9.jar:/home/odomontois/.ivy2/cache/org.typelevel/catalysts-macros_2.12/jars/catalysts-macros_2.12-0.0.5.jar:/home/odomontois/.ivy2/cache/org.typelevel/catalysts-platform_2.12/jars/catalysts-platform_2.12-0.0.5.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-core_2.12/jars/cats-core_2.12-1.0.0-RC1.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-effect_2.12/jars/cats-effect_2.12-0.5.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-free_2.12/jars/cats-free_2.12-1.0.0-RC1.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-jvm_2.12/jars/cats-jvm_2.12-0.9.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-kernel-laws_2.12/jars/cats-kernel-laws_2.12-0.9.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-kernel_2.12/jars/cats-kernel_2.12-1.0.0-RC1.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-laws_2.12/jars/cats-laws_2.12-0.9.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-macros_2.12/jars/cats-macros_2.12-1.0.0-RC1.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats-mtl-core_2.12/jars/cats-mtl-core_2.12-0.1.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/cats_2.12/jars/cats_2.12-0.9.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/discipline_2.12/jars/discipline_2.12-0.7.2.jar:/home/odomontois/.ivy2/cache/org.typelevel/export-hook_2.12/jars/export-hook_2.12-1.2.0.jar:/home/odomontois/.ivy2/cache/org.typelevel/machinist_2.12/jars/machinist_2.12-0.6.2.jar:/home/odomontois/.ivy2/cache/org.typelevel/macro-compat_2.12/jars/macro-compat_2.12-1.1.1.jar:/home/odomontois/.ivy2/cache/org.typelevel/scala-compiler/jars/scala-compiler-2.12.3-bin-typelevel-4.jar:/home/odomontois/.ivy2/cache/org.typelevel/scala-library/jars/scala-library-2.12.3-bin-typelevel-4.jar:/home/odomontois/.ivy2/cache/org.typelevel/scala-reflect/jars/scala-reflect-2.12.3-bin-typelevel-4.jar:/home/odomontois/.ivy2/cache/org.typelevel/spire-macros_2.12/jars/spire-macros_2.12-0.14.1.jar:/home/odomontois/.ivy2/cache/org.typelevel/spire_2.12/jars/spire_2.12-0.14.1.jar bench.LanguageStore
java.lang.StackOverflowError
at scala.collection.immutable.Queue.dequeue(Queue.scala:151)
at monix.execution.misc.AsyncVar$WaitForPut.dequeue(AsyncVar.scala:315)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1(MVar.scala:119)
at monix.eval.MVar$AsyncMVarImpl.$anonfun$put$1$adapted(MVar.scala:116)
at monix.eval.internal.TaskRunLoop$.executeOnFinish$1(TaskRunLoop.scala:166)
at monix.eval.internal.TaskRunLoop$.monix$eval$internal$TaskRunLoop$$loop$1(TaskRunLoop.scala:243)
at monix.eval.internal.TaskRunLoop$RestartCallback$1.onSuccess(TaskRunLoop.scala:127)
at monix.eval.Callback.onValue(Callback.scala:42)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
at monix.execution.misc.AsyncVar.unsafePut(AsyncVar.scala:111)
at monix.execution.misc.AsyncVar$$anon$2.onValue(AsyncVar.scala:239)
Process finished with exit code 130 (interrupted by signal 2: SIGINT)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment