Skip to content

Commit

Permalink
hm
Browse files Browse the repository at this point in the history
  • Loading branch information
ValdemarGr committed Sep 3, 2024
1 parent b85fdd5 commit 66470a8
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -126,12 +126,16 @@ object NewDesign {
path: Set[Unique.Token],
h: Hierarchy[Stream[IO, Collect[IO]]],
chan: IO[Channel[IO, Collect[IO]]]
) = {
): IO[List[Fiber[IO, Throwable, Unit]]] = {
h.children.map{ case (col, child) =>
IO.unique.map{ tok =>
val newPath = path + tok
registerHierarchy(newPath, child, chan).map{ children =>
val killAll = children.parTraverse(_.cancel)
}
}
}
???
}

// pulle side:
Expand Down

0 comments on commit 66470a8

Please sign in to comment.