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

fixed typo call to emitMultiple

Browse source
This commit is contained in:
lolski 2015-12-09 01:26:42 +08:00
parent fca478c763
commit 3152a6d15f
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/impl/fusing/Ops.scala
View file

@ -250,19 +250,19 @@ final case class Intersperse[T](start: Option[T], inject: T, end: Option[T]) ext
val startInHandler = new InHandler {
override def onPush(): Unit = {
// if else (to avoid using Iterator[T].flatten in hot code)
if (start.isDefined) emitMultipe(out, Iterator(start.get, grab(in)))
if (start.isDefined) emitMultiple(out, Iterator(start.get, grab(in)))
else emit(out, grab(in))
setHandler(in, restInHandler) // switch handler
}
override def onUpstreamFinish(): Unit = {
emitMultipe(out, Iterator(start, end).flatten)
emitMultiple(out, Iterator(start, end).flatten)
completeStage()
}
}
val restInHandler = new InHandler {
override def onPush(): Unit = emitMultipe(out, Iterator(inject, grab(in)))
override def onPush(): Unit = emitMultiple(out, Iterator(inject, grab(in)))
override def onUpstreamFinish(): Unit = {
if (end.isDefined) emit(out, end.get)