Topic version 1

object TopicPlayground extends App {

  val t: Topic[String] = scalaz.stream.async.topic()

  val sub1 = t.subscribe

  val out1 = sub1

    .flatMap(x => Process.tell(s"raw value: $x") ++ Process.emitO(x.length))

  t.publishOne("foo")

  t.close

  val oneRun = out1.runLog.run

  println(s"oneRun: $oneRun")

}