com.radixdlt.client.core.ledger

Class RadixAtomPuller

java.lang.Object

com.radixdlt.client.core.ledger.RadixAtomPuller

All Implemented Interfaces:

AtomPuller

public class RadixAtomPuller
extends java.lang.Object
implements AtomPuller

Module responsible for fetches and merges of new atoms into the Atom Store.

Constructor Summary

Constructors

Constructor and Description
RadixAtomPuller(RadixNetworkController controller)

Method Summary

Modifier and Type	Method and Description
io.reactivex.Observable<java.lang.Object>	pull(RadixAddress address) Fetches atoms and pushes them into the atom store.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RadixAtomPuller

public RadixAtomPuller(RadixNetworkController controller)

Method Detail

pull

public io.reactivex.Observable<java.lang.Object> pull(RadixAddress address)

Fetches atoms and pushes them into the atom store. Multiple pulls on the same address will return a disposable to the same observable. As long as there is one subscriber to an address this will continue fetching and storing atoms.

Specified by:

pull in interface AtomPuller

Parameters:

address - shard address to get atoms from

Returns:

disposable to dispose to stop fetching