Search code examples
scalaakkaakka-stream

How to put contents of stream into a val?

I have a stream like this:

def myStream[T: AS: MAT](source: Source[T, NotUsed]): Future[Seq[T]] = {
    return source.runWith(Sink.seq)
}

def myMethod(colorStream: Source[Color, NotUsed]) {
  val allColors = myStream(colorStream).map(_.toList)

  //how can I actually extract the things from allColors
  //so that I can call my method below? myOtherMethod

  if I do println(allColors.map(println _)) I can print the elements fine
}

def myOtherMethod(colors: Seq[Color] = List.empty()) {
 ...
}
Solution

  • allColors is a Future. You need to access what the future is wrapping to access the colours:Seq[Color]. Try this:

    allColors.onComplete{
  case Success(list) => myOtherMethod(list)
  case Failure(err) => //handle the error
}