deadlock.scala

var closure = 1
val generator = Task {
  if (closure > 5) {
    throw Process.End
  }
  
  val back = closure
  closure += 1
  back
}

val source: Process[Task, Int] = Process eval generator repeat

val partitioned: Writer[Task, Int, Int] = source map {
  case x if x % 2 == 0 => -\/(x)
  case x if x % 2 == 1 => \/-(x)
}

val channel: Channel[Task, Int, String] = Process.eval(Task now ({ i: Int =>
  Task delay {
    Thread.sleep(100)
    i.toString
  }
})).repeat

partitioned.connectO(channel)(wye.boundedQueue(10)).runLog.run