Hi All!
I again have question about Akka Streams, now I have task like: I have
`Seq[URL]` to files, need download it, process via some stages and than
upload result to different place. When I try to do it use code like this:
Source(images.to[scala.collection.immutable.Seq])
.map { image =>
Get(image.uri)
}
.via(httpFlow)
.map { response =>
response.entity.dataBytes: Source[ByteString, Any]
}
I get Source inside Stream... and to process it source I need to run Stream
inside Stream - I want something like `flatMap` operation that allowed me
to operate with `ByteString` from response source in my current stream, not
inside other chain
Any ideias?
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
