net.corda.core.messaging

Class DataFeed<A,B>

net.corda.core.messaging.DataFeed<A,B>

public class DataFeed<A,B>

The Data feed contains a snapshot of the requested data and an Observable of future updates.

Constructor Detail

DataFeed

public DataFeed(A snapshot,
                @NotNull
                rx.Observable<B> updates)

The Data feed contains a snapshot of the requested data and an Observable of future updates.

Method Detail

getSnapshot

public A getSnapshot()

getUpdates

@NotNull
public rx.Observable<B> getUpdates()

component1

public A component1()

component2

@NotNull
public rx.Observable<B> component2()

copy

@NotNull
public DataFeed<A,B> copy(A snapshot,
                                   @NotNull
                                   rx.Observable<B> updates)

The Data feed contains a snapshot of the requested data and an Observable of future updates.

toString

@NotNull
public java.lang.String toString()

The Data feed contains a snapshot of the requested data and an Observable of future updates.

hashCode

public int hashCode()

The Data feed contains a snapshot of the requested data and an Observable of future updates.

equals

public boolean equals(@Nullable
                      java.lang.Object p)

The Data feed contains a snapshot of the requested data and an Observable of future updates.