# Converting an existing HZ instance to RxHazelcastInstance RxHazelcastInstance rxInstance = RxHazelcast.from(instance);

# Creating new RxIMap instance RxIMap rxIMap = RxHazelcastInstance.getMap("map-name");

# Converting an existing IMap instance to RxIMap RxImap rxIMap = RxHazelcast.from(imap);

# Creating new Ringbuffer instance RxRingbuffer rxRingbuffer = RxHazelcastInstance.getRingbuffer("ringbuffer-name");

# Converting an existing Ringbuffer instance to RxRingbuffer RxRingbuffer rxRingbuffer = RxHazelcast.from(ringbuffer);

# Creating new IAtomicReference instance IAtomicReference<Long> reference = RxHazelcastInstance.getAtomicReference("reference-name");

# Converting an existing IAtomicReference instance to RxAtomicReference RxAtomicReference rxReference = RxHazelcast.from(reference);

# Creating new IAtomicLong instance IAtomicLong atomicLong = RxHazelcastInstance.getAtomicLong("long-name");

# Converting an existing IAtomicReference instance to RxAtomicReference RxAtomicLong rxAtomicLong = RxHazelcast.from(atomicLong);

RxIMap<String, Float> rxCurrency = RxHazelcast.from(currency); RxIMap<String, Float> rxCommission = RxHazelcast.from(commission); RxRingbuffer<Exchange> rxToProcess = RxHazelcast.from(exchange); RxRingbuffer<ProcessedExchange> rxProcessed = RxHazelcast.from(processed); rxToProcess.readMany(0, 1, 10, null) .flatMap(exchange -> { log.info("Processing exchange" + exchange); String fromTo = exchange.from + exchange.to; return Observable.zip( rxCurrency.get(fromTo), rxCommission.get(fromTo), (exchangeRate, commissionPercentage) -> { Float commission = exchange.amount * commissionPercentage; Float targetAmount = exchange.amount * exchangeRate; return new ProcessedExchange(exchange.id, targetAmount, commission); }); }) .flatMap(processedExchange -> { log.info("Storing exchange" + processedExchange); return rxProcessed.add(processedExchange, OverflowPolicy.FAIL); }).subscribe(subscriber); subscriber.awaitTerminalEvent(10, TimeUnit.SECONDS);