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

Added explicit buffers section

Browse source
This commit is contained in:
Endre Sándor Varga 2014-12-22 13:25:06 +01:00
parent de982b0607
commit fc8560afa9
2 changed files with 68 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -57,4 +57,31 @@ class StreamBuffersRateSpec extends AkkaSpec {
//#buffering-abstraction-leak
}
"explcit buffers" in {
trait Job
def inboundJobsConnector(): Source[Job] = Source.empty()
//#explicit-buffers-backpressure
// Getting a stream of jobs from an imaginary external system as a Source
val jobs: Source[Job] = inboundJobsConnector()
jobs.buffer(1000, OverflowStrategy.backpressure)
//#explicit-buffers-backpressure
//#explicit-buffers-droptail
jobs.buffer(1000, OverflowStrategy.dropTail)
//#explicit-buffers-droptail
//#explicit-buffers-drophead
jobs.buffer(1000, OverflowStrategy.dropHead)
//#explicit-buffers-drophead
//#explicit-buffers-dropbuffer
jobs.buffer(1000, OverflowStrategy.dropBuffer)
//#explicit-buffers-dropbuffer
//#explicit-buffers-error
jobs.buffer(1000, OverflowStrategy.error)
//#explicit-buffers-error
}
}