Web on Reactive Stack Version 5.3.36-SNAPSHOT ## Table of Contents 1. Spring WebFlux ..... 2 1.1. Overview ..... 2 1.1.1. Define "Reactive" ..... 2 1.1.2. Reactive API ..... 3 1.1.3. 1.1.5. Servers ..... 5 1.1.6. Performance ..... 5 1.1.7. Concurrency Model ..... 6 1.2. Reactive Core ..... 7 1.2.1. HttpHandler ..... 7 1.2.2. WebHandler API ..... 10 Special bean types MetadataExtractor ..... 173 Reactive Libraries ..... 176 This part of the documentation covers support for reactive-stack web applications built on a Reactive Streams API to run on non-blocking servers

back. • Request-Stream—send one message and receive a stream of messages back. • Channel — send streams of messages in both directions. • Fire-and-Forget — send a one-way message. Once the initial connection interactions are called "request streams" or simply "requests". These are the key features and benefits of the RSocket protocol: • Reactive Streams semantics across network boundary—for library is built on Project Reactor, and Reactor Netty for the transport. That means signals from Reactive Streams Publishers in your application propagate transparently through RSocket across the network.

Analytics Spring 2020 ## 4 /21: Sampling and filtering streams Vasiliki (Vasia) Kalavri vkalavri@bu.edu ## Synopses for massive data streams Synopsis: a lossy, compact summary of the input stream means of providing interactive response times when exploring massive datasets or high speed data streams. • Queries are executed against the synopsis rather than the entire dataset. ## A simple and efficient answer is roughly $5 million without knowing that the exact answer is $5,001,482.76. ## Sampling streams ## Samples: the most fundamental synopses A sample is a set of data elements selected via some random

User interaction and data binding MODEL Notification ## MVVM: MODEL-VIEW-VIEWMODEL THE GOOD • Reactive UI data binding • Increased testability! • First viable contender to MVC (within iOS) • Post-MVC PRINCIPLES • iOS first and foremost • Enforce unidirectional flow • Utilise immutability • Include reactive elements • Embrace Swift's functionality • Strong guidelines ## CONSUME ## USING A PRE-EXISTING STATE ENTITY ## DEMO LET'S SEE IT IN ACTION ## DEMO NOTES ## NEMO - Delegates were used, but Reactive programming would make it much easier to code. ReactiveSwift, RxSwift, etc... • Typecasing enums

ServletWebServerApplicationContext 246 Customizing Embedded Servlet Containers 247 JSP Limitations 252 8.2. Reactive Web Applications 252 8.2.1. The "Spring WebFlux Framework" 252 Spring WebFlux Auto-configuration Template Engines 260 Error Handling 261 Web Filters 266 8.2.2. Embedded Reactive Server Support 266 8.2.3. Reactive Server Resources Configuration 266 8.3. Graceful Shutdown 267 8.4. Spring Kafka Support 344 10.3.1. Sending a Message 345 10.3.2. Receiving a Message 346 10.3.3. Kafka Streams 347 10.3.4. Additional Kafka Properties 348 10.3.5. Testing with Embedded Kafka 350 10.4. RSocket

Customizing Embedded Servlet Containers 136 JSP Limitations 138 7.7.5. Embedded Reactive Server Support 138 7.7.6. Reactive Server Resources Configuration 139 7.8. Graceful shutdown 139 7.9. RSocket 177 Connecting to Elasticsearch using REST clients ..... 177 Connecting to Elasticsearch using Reactive REST clients ..... 178 Connecting to Elasticsearch by Using Spring Data ..... 179 Spring Data Apache Kafka Support ..... 208 Sending a Message ..... 208 Receiving a Message ..... 209 Kafka Streams ..... 210 Additional Kafka Properties ..... 211 Testing with Embedded Kafka ..... 213 7.15. Calling

.... 291 Customizing Embedded Servlet Containers ..... 292 JSP Limitations ..... 297 8.2. Reactive Web Applications ..... 297 8.2.1. The "Spring WebFlux Framework" ..... 297 Spring WebFlux Handling ..... 306 Web Filters ..... 312 8.2.2. Embedded Reactive Server Support ..... 312 Customizing Reactive Servers ..... 312 8.2.3. Reactive Server Resources Configuration ..... 315 8.3. Graceful 407 10.3.1. Sending a Message ..... 408 10.3.2. Receiving a Message ..... 409 10.3.3. Kafka Streams ..... 410 10.3.4. Additional Kafka Properties ..... 411 10.3.5. Testing with Embedded Kafka ..

Servlet Containers ..... 133 JSP Limitations ..... 135 5.7.5. Embedded Reactive Server Support ..... 135 5.7.6. Reactive Server Resources Configuration ..... 136 5.8. Graceful shutdown ..... 136 174 Connecting to Elasticsearch using REST clients ..... 174 Connecting to Elasticsearch using Reactive REST clients ..... 175 Connecting to Elasticsearch by Using Spring Data ..... 176 Spring Data Apache Kafka Support ..... 205 Sending a Message ..... 205 Receiving a Message ..... 206 Kafka Streams ..... 207 Additional Kafka Properties ..... 208 Testing with Embedded Kafka ..... 210 5.15

Customizing Embedded Servlet Containers 136 JSP Limitations 138 7.7.5. Embedded Reactive Server Support 138 7.7.6. Reactive Server Resources Configuration 139 7.8. Graceful shutdown 139 7.9. RSocket 177 Connecting to Elasticsearch using REST clients ..... 177 Connecting to Elasticsearch using Reactive REST clients ..... 178 Connecting to Elasticsearch by Using Spring Data ..... 179 Spring Data Apache Kafka Support ..... 208 Sending a Message ..... 208 Receiving a Message ..... 209 Kafka Streams ..... 210 Additional Kafka Properties ..... 211 Testing with Embedded Kafka ..... 213 7.15. Calling

.... 259 Customizing Embedded Servlet Containers ..... 260 JSP Limitations ..... 265 8.2. Reactive Web Applications ..... 265 8.2.1. The "Spring WebFlux Framework" ..... 265 Spring WebFlux Handling ..... 274 Web Filters ..... 280 8.2.2. Embedded Reactive Server Support ..... 280 Customizing Reactive Servers ..... 280 8.2.3. Reactive Server Resources Configuration ..... 283 8.3. Graceful 367 10.3.1. Sending a Message ..... 368 10.3.2. Receiving a Message ..... 369 10.3.3. Kafka Streams ..... 370 10.3.4. Additional Kafka Properties ..... 371 10.3.5. Testing with Embedded Kafka