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

Merge pull request #16756 from akka/wip-16448-err-vs-fail-patriknw

Browse source 
!str #16448 Change error to failure
This commit is contained in:
Patrik Nordwall 2015-02-03 13:45:28 +01:00
commit b442c4d9e6
31 changed files with 83 additions and 84 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-docs-dev/rst/scala/code/docs/stream/StreamBuffersRateSpec.scala
View file

@ -79,9 +79,9 @@ class StreamBuffersRateSpec extends AkkaSpec {
jobs.buffer(1000, OverflowStrategy.dropBuffer)
//#explicit-buffers-dropbuffer
//#explicit-buffers-error
jobs.buffer(1000, OverflowStrategy.error)
//#explicit-buffers-error
//#explicit-buffers-fail
jobs.buffer(1000, OverflowStrategy.fail)
//#explicit-buffers-fail
}

4
akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeReduceByKey.scala
View file

@ -31,7 +31,7 @@ class RecipeReduceByKey extends RecipeSpec {
// get a stream of word counts
val counts: Source[(String, Int)] =
countedWords
.buffer(MaximumDistinctWords, OverflowStrategy.error)
.buffer(MaximumDistinctWords, OverflowStrategy.fail)
.mapAsync(identity)
//#word-count
@ -62,7 +62,7 @@ class RecipeReduceByKey extends RecipeSpec {
}
}
reducedValues.buffer(maximumGroupSize, OverflowStrategy.error).mapAsync(identity)
reducedValues.buffer(maximumGroupSize, OverflowStrategy.fail).mapAsync(identity)
}
val wordCounts = words.via(reduceByKey(