raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Merge branch 'wip-delete-futurepublisher-√' into wip-remove-synchronousiterablepublisher-√

Browse source
This commit is contained in:
Viktor Klang 2015-06-06 16:28:18 +02:00
commit 91e9396083
5 changed files with 8 additions and 184 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
View file

@ -221,7 +221,7 @@ object Source extends SourceApply {
* The stream terminates with a failure if the `Future` is completed with a failure.
*/
def apply[T](future: Future[T]): Source[T, Unit] =
new Source(new FutureSource(future, DefaultAttributes.futureSource, shape("FutureSource")))
Source.single(future).mapAsync(1)(identity).withAttributes(DefaultAttributes.futureSource)
/**
* Elements are emitted periodically with the specified interval.