corda / net.corda.core.messaging / DataFeed

DataFeed

data class DataFeed<out A, B>

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

Constructors

<init>

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

DataFeed(snapshot: A, updates: Observable<B>)

Properties

snapshot

val snapshot: A

updates

val updates: Observable<B>

Extension Functions

doOnError

Returns a DataFeed that processes errors according to the provided action.

fun <SNAPSHOT, ELEMENT> DataFeed<SNAPSHOT, ELEMENT>.doOnError(action: (Throwable) -> Unit): DataFeed<SNAPSHOT, ELEMENT>

mapErrors

Returns a DataFeed that transforms errors according to the provided transform function.

fun <SNAPSHOT, ELEMENT> DataFeed<SNAPSHOT, ELEMENT>.mapErrors(transform: (Throwable) -> Throwable): DataFeed<SNAPSHOT, ELEMENT>