Package io.deephaven.kv

Class KeyValuesCollectionListener.StateAdapter<T>

java.lang.Object

io.deephaven.kv.KeyValuesCollectionListener.StateAdapter<T>

Type Parameters:

T - the state type

All Implemented Interfaces:

KeyValuesCollectionListener

Enclosing interface:

KeyValuesCollectionListener

public static class KeyValuesCollectionListener.StateAdapter<T>
extends Object
implements KeyValuesCollectionListener

Adapts a WatchClient.StateListener into a KeyValuesCollection.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.kv.KeyValuesCollectionListener

KeyValuesCollectionListener.StateAdapter<T>

Constructor Summary

Constructors

Constructor	Description
StateAdapter(@NotNull WatchClient.StateListener<T> listener, @NotNull KeyValuesCollectionParser<Optional<T>> parser)

Method Summary

Modifier and Type	Method	Description
void	onCompleted()	Invoked on completion.
void	onError(@NotNull Throwable t)	Invoked on errors.
void	onInitialState(@NotNull HeaderResponse header, @NotNull KeyValuesCollection collection)	Initializes the listener with the full initial state.
void	onNextState(@NotNull WatchResponseUnit unit, @NotNull KeyValuesCollection collection)	Invoked on updates.

Methods inherited from class java.lang.Object

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

Constructor Details

StateAdapter

public StateAdapter(@NotNull
 @NotNull WatchClient.StateListener<T> listener,
 @NotNull
 @NotNull KeyValuesCollectionParser<Optional<T>> parser)

Method Details

onInitialState

public void onInitialState(@NotNull
 @NotNull HeaderResponse header,
 @NotNull
 @NotNull KeyValuesCollection collection)

Description copied from interface: KeyValuesCollectionListener

Initializes the listener with the full initial state.

Listeners that want to hold on to the state must call KeyValuesCollection.asImmutable().

Note: if there is an exception after this call, but before WatchClient.Watch.startWatch() is called, the exception is *not* presented to this listener. (Todo: consider changing this.)

Specified by:

onInitialState in interface KeyValuesCollectionListener

Parameters:

header - the header

collection - the key values state

onNextState

public void onNextState(@NotNull
 @NotNull WatchResponseUnit unit,
 @NotNull
 @NotNull KeyValuesCollection collection)

Description copied from interface: KeyValuesCollectionListener

Invoked on updates.

Listeners that want to hold on to the state must call KeyValuesCollection.asImmutable().

Specified by:

onNextState in interface KeyValuesCollectionListener

Parameters:

unit - the watch response unit

collection - the key values state AFTER applying unit changes

onError

public void onError(@NotNull
 @NotNull Throwable t)

Description copied from interface: KeyValuesCollectionListener

Invoked on errors.

May only be called once and if called it must be the last method called.

Specified by:

onError in interface KeyValuesCollectionListener

Parameters:

t - the error

onCompleted

public void onCompleted()

Description copied from interface: KeyValuesCollectionListener

Invoked on completion.

May only be called once and if called it must be the last method called.

Specified by:

onCompleted in interface KeyValuesCollectionListener