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

Merge pull request #16328 from akka/wip-remove-async-iterable-publisher-√

Browse source 
+str - Removes AsynchronousIterablePublisher
This commit is contained in:
Viktor Klang (√) 2014-11-18 22:06:36 +01:00 • committed by Viktor Klang
commit 8f4e099bec
5 changed files with 6 additions and 331 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

@ -107,7 +107,7 @@ object Source {
* stream will see an individual flow of elements (always starting from the
* beginning) regardless of when they subscribed.
*/
def apply[T](iterable: immutable.Iterable[T]): Source[T] = IterableSource(iterable, ExecutionContext.global) // FIXME can't be global!
def apply[T](iterable: immutable.Iterable[T]): Source[T] = IterableSource(iterable)
/**
* Start a new `Source` from the given `Future`. The stream will consist of