A set of small examples using Scala & Pekko.
This is a great starter crash course in Akka Streams, and the concepts here are identical in Pekko.
sbt run # then see the TOC for the available examples
# OR
make run
A simple example of a couple of punk actors sending messages to each other.
From the Quick Start guide.
From the IoT example.
Shows that an overwhelmed actor mailbox will drop messages.
Shows that an overwhelmed blocking actor mailbox will block the sender.
Shows that a parent actor can stop its children when one of them fails.
Shows that a parent actor can restart its children when one of them fails.
Shows how to "ask" an actor and get a result.
Demonstrates natural backpressure when a router is overwhelmed.
A very simple Source->Sink flow
File processing with streams, asynchronously, but in sequence.
Same as SequentialIoApp, but with parallelism.
A flow with context, carrying state of interest through the stream.
make test
make test-focused
To tag a test with Focused, add the Focused tag to the test, like this:
test("BoundedMailboxApp should receive one dead letter", Focused) {
... test here
}make lint