Android Implementing Google Sign In

As you all are aware that Google Plus is shutting down in March 2019 and so are all its services. I have had a legacy android app on play store that was using the GoogleApiClient for authentication with Google Plus services, alas, I had to upgrade the application to use the new GoogleSignInClient. And, I am glad that I did so for the following reasons: GoogleSignInClient API is based on Task Api It does not involve managing connection as with GoogleApiClient API's, so no callback...

Read More

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 addition, there is a WatchService that monitors the directory for changes, specifically only creation and removal of CSV files. Let's start with the pieces We want to access the records...

Read More

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 CSVRecord (commons-csv) by converting iterator to Flowable using the call Flowable.fromIterable(). Next, we want this to be safe resource usage i.e. we don't want to leave open file handles, so...

Read More