From d2885c59b49fc55235986f607321160db869258d Mon Sep 17 00:00:00 2001 From: Alexandre Archambault Date: Thu, 25 Jun 2015 00:18:53 +0100 Subject: [PATCH] Add stream method to Resolution --- core/src/main/scala/coursier/core/Resolution.scala | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/core/src/main/scala/coursier/core/Resolution.scala b/core/src/main/scala/coursier/core/Resolution.scala index f03f5ad67..2b4805daf 100644 --- a/core/src/main/scala/coursier/core/Resolution.scala +++ b/core/src/main/scala/coursier/core/Resolution.scala @@ -606,6 +606,13 @@ case class Resolution(rootDependencies: Set[Dependency], } } + def stream(fetchModule: ModuleVersion => EitherT[Task, List[String], (Repository, Project)], run: Task[Resolution] => Resolution): Stream[Resolution] = { + this #:: { + if (isDone) Stream.empty + else run(next(fetchModule)).stream(fetchModule, run) + } + } + def minDependencies: Set[Dependency] = Orders.minDependencies(dependencies) }