List of Listings

 

Chapter 2. A walk-through of the Reactive Manifesto

Listing 2.1. Excerpt from a simple controller for an image service

Chapter 3. Tools of the trade

Listing 3.1. Unsafe, mutable message class, which may hide unexpected behavior

Listing 3.2. Immutable message class that behaves predictably and is easier to reason about

Listing 3.3. Referential transparency: allowing substitution of precomputed values

Listing 3.4. Limiting usability with side effects

Listing 3.5. Retrieving the result from the faster source

Listing 3.6. Aggregating a single result from two futures in Scala

Listing 3.7. An Actor example in Akka

Chapter 11. Testing reactive applications

Listing 11.1. Testing a purely synchronous translation function

Listing 11.2. Awaiting the result blocks synchronously on the translation

Listing 11.3. Expecting replies with a TestProbe

Listing 11.4. Using a TestProbe to receive the response from the scheduler

Listing 11.5. Determining 95th percentile latency

Listing 11.6. Generating the test samples in parallel with the Ask pattern

Listing 11.7. Using a custom Actor to bound the number of parallel test samples

Listing 11.8. Verifying that no additional messages are received

Listing 11.9. Matching responses to requests with a correlation ID

Listing 11.10. Forcing synchronous execution: safe only for nonblocking processes

Listing 11.11. Processing messages on the calling thread with CallingThreadDispatcher

Listing 11.12. Moving the timeout parameters to an external configuration