In the following example, we will show the usage of RxJava in the real-time processing of the temperature received from multiple sensors. The sensor data is provided (randomly generated) by a Spring Boot server. The server is configured to accept the sensor name as a configuration so that we may change it for each instance. We'll start five instances and display warnings on the client side if one of the sensors outputs more than 80 degrees Celsius.
Starting multiple sensors is easily done from bash with the following command:
The server-side code is simple, we have only one REST controller configured to output the sensor data as JSON, as shown in the following code:
@RestController
publicclass SensorController
{
@Value("${sensor.name}")
private String sensorName;
@RequestMapping(value="/sensor", method=RequestMethod.GET,
produces=MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<SensorData> sensor() throws Exception
{
SensorData data = new SensorData...