Package io.deephaven.enterprise.webclientdata2

Class KeyPresenceStreamPublisher

java.lang.Object

io.deephaven.enterprise.webclientdata2.KeyPresenceStreamPublisher

All Implemented Interfaces:

StreamPublisher

public class KeyPresenceStreamPublisher
extends Object
implements StreamPublisher

Field Summary

Fields

Modifier and Type	Field	Description
static final String	GEN_COLUMN_NAME
static final String	KEY_FOR_PRESENCE_COLUMN_NAME

Method Summary

Modifier and Type	Method	Description
void	acceptFailure(Throwable e)
void	add(long key, long gen)
static TableDefinition	definition()
void	flush()
void	register(@NotNull StreamConsumer consumer)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

KEY_FOR_PRESENCE_COLUMN_NAME

public static final String KEY_FOR_PRESENCE_COLUMN_NAME

See Also:

• Constant Field Values

GEN_COLUMN_NAME

public static final String GEN_COLUMN_NAME

See Also:

• Constant Field Values

Method Details

definition

public static TableDefinition definition()

register

public void register(@NotNull
 @NotNull StreamConsumer consumer)

Specified by:

register in interface StreamPublisher

add

public void add(long key,
 long gen)

flush

public void flush()

Specified by:

flush in interface StreamPublisher

acceptFailure

public void acceptFailure(Throwable e)

shutdown

public void shutdown()

Specified by:

shutdown in interface StreamPublisher