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

!str switch to a stable Source.empty val

Browse source
This commit is contained in:
Mathias 2014-10-30 17:04:36 +01:00 • committed by Johannes Rudolph
parent 292afaa4d0
commit 57efc12fb1
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -167,10 +167,10 @@ object Source {
def singleton[T](element: T): Source[T] = apply(SynchronousPublisherFromIterable(List(element))) def singleton[T](element: T): Source[T] = apply(SynchronousPublisherFromIterable(List(element)))
/** /**
* Create a `Source` with no elements, i.e. an empty stream that is completed immediately * A `Source` with no elements, i.e. an empty stream that is completed immediately for every connected `Sink`.
* for every connected `Sink`.
*/ */
def empty[T](): Source[T] = apply(EmptyPublisher[T]) def empty[T](): Source[T] = _empty
private[this] val _empty: Source[Nothing] = apply(EmptyPublisher)
/** /**
* Create a `Source` that immediately ends the stream with the `cause` error to every connected `Sink`. * Create a `Source` that immediately ends the stream with the `cause` error to every connected `Sink`.