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

=str - Introduces a TCK-verified SingleElementPublisher to optimize Source.single and things depending on it

Browse source
This commit is contained in:
Viktor Klang 2015-06-06 16:07:35 +02:00
parent 23a3d8d5fc
commit 8165c806fc
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -243,13 +243,16 @@ object Source extends SourceApply {
* Every connected `Sink` of this stream will see an individual stream consisting of one element. * Every connected `Sink` of this stream will see an individual stream consisting of one element.
*/ */
def single[T](element: T): Source[T, Unit] = def single[T](element: T): Source[T, Unit] =
apply(SingleElementPublisher(element, "SingleSource")).withAttributes(DefaultAttributes.singleSource) // FIXME optimize apply(SingleElementPublisher(element, "SingleSource")).withAttributes(DefaultAttributes.singleSource)
/** /**
* Create a `Source` that will continually emit the given element. * Create a `Source` that will continually emit the given element.
*/ */
def repeat[T](element: T): Source[T, Unit] = def repeat[T](element: T): Source[T, Unit] =
apply(() ⇒ Iterator.continually(element)).withAttributes(DefaultAttributes.repeat) // FIXME optimize apply(new immutable.Iterable[T] {
override val iterator: Iterator[T] = Iterator.continually(element)
override def toString: String = "Iterable.continually(" + element + ")"
}).withAttributes(DefaultAttributes.repeat)
/** /**
* A `Source` with no elements, i.e. an empty stream that is completed immediately for every connected `Sink`. * A `Source` with no elements, i.e. an empty stream that is completed immediately for every connected `Sink`.