Java WatchService

In this post, I will cover a tutorial that involves different moving pieces. It covers the following:

• Java WatchService
• Spring Boot
• Initialization-on-demand holder idiom
• Managing concurrency
• RXJava
• Lombok (because why type more?)

The example will expose a Spring Boot REST service that exposes csv file records from a directory. In …

in java · Fri 21 December 2018

Reactively Streaming CSV using RXJava

RXJava is an extremely useful streaming framework (here is an example application using it for parallel processing of restful calls to both uber and lyft (RT_UBER_NYC_TAXI)). However, In this post, I will cover how you can reactively stream and process a CSV file.

Firstly, you can create a Flowable of …

in java · Sat 15 December 2018