RxRedisClient client = new RxRedisClient("redis://localhost:6379"); client.get("key") .subscribe(result -> System.out.println("Value: " + result), error -> System.err.println("Failed: " + error.getMessage())); client.set("key", "value") .flatMap(response -> client.get("key")) .subscribe(result -> System.out.println("Updated value: " + result), error -> System.err.println("Failed: " + error.getMessage())); client.close();