RedisClient client = RedisClient.create("redis://localhost"); Observable<String> setObservable = client.rxSet("key", "value"); Observable<String> getObservable = client.rxGet("key"); Observable.zip(setObservable, getObservable, (setResult, getResult) -> { System.out.println("Set result: " + setResult); System.out.println("Get result: " + getResult); return null; }) .subscribe(); client.shutdown().await();