itzap-rxjava – Reactive Programming

Command Pattern

Command pattern can be extended using RxJava to create a robust application code. This idea is an extension of the NetflixObservableCommand.

Vision Statement

Create a lightweight extensible library that implements a command pattern with RxJava extension. This library should provide an easy way to create commands and turning them into Reactive Observables. Commands will wrap exception handling and provide execution time metric for tracability.

Use Case

In Service-Oriented Programming, it is a common need to combine results of one service execution with the result of another service execution. This is a good fit for the command pattern. However, it would be great to be able to execute services in parallel whenever possible. Creating a reactive application service layer makes a robust and efficient solution for business logic implementation.

Other Solutions

Already mentioned NetflixObservableCommand can be used to implement reactive services.

Why itzap-rxjava

itzap–rxjava provides and easy way to turn any executable code into RxJava observable. For example

    public Observable<Pair[]> read() {
        return new RunnableCommand<Pair[]>("cmd-read-flatFile") {
            @Override
            protected Pair[] run() {
                // do some processing
                return new Pair[0];
            }
        }.toObservable();
    }
Code language: PHP (php)

In this example, file processing code is wrapped into RxJava Observable with ease. In addition, itzap-rxjava will provide logging statements that would measure execution time.

Code