Package com.inductiveautomation.eventstream.designer.ui.viewmodel.statetracker

Class EventStreamStateTracker

java.lang.Object

com.inductiveautomation.eventstream.designer.ui.viewmodel.statetracker.EventStreamStateTracker

All Implemented Interfaces:

Disposable

public class EventStreamStateTracker
extends Object
implements Disposable

This class tracks the state of the event stream as reported by the Gateway, by using the EventStreamPushReceiver.

You can add listeners to this class to get notified when states change via addListener(EventStreamStateTrackerListener).

Field Summary

Fields

Modifier and Type	Field	Description
protected final EventStreamRpc	rpc

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EventStreamStateTracker(String projectName, String resourceFolderPath, EventStreamPushReceiver receiver, EventStreamRpc rpc, ViewModelSwingWorkerExecutor executor)

Method Summary

Modifier and Type	Method	Description
void	addListener(EventStreamStateTrackerListener listener)
static EventStreamStateTracker	create(String projectName, String resourceFolderPath, EventStreamPushReceiver receiver, EventStreamRpc rpc, ViewModelSwingWorkerExecutor executor)
void	dispose()
protected EventStreamState	getStateFromRpc()
void	initialize()
void	removeListener(EventStreamStateTrackerListener listener)
protected void	retrieveStateAsync()
protected void	setEventStreamState(EventStreamState state)

Methods inherited from class java.lang.Object

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

Field Details

rpc

protected final EventStreamRpc rpc

Constructor Details

EventStreamStateTracker

protected EventStreamStateTracker(String projectName,
 String resourceFolderPath,
 EventStreamPushReceiver receiver,
 EventStreamRpc rpc,
 ViewModelSwingWorkerExecutor executor)

Method Details

create

public static EventStreamStateTracker create(String projectName,
 String resourceFolderPath,
 EventStreamPushReceiver receiver,
 EventStreamRpc rpc,
 ViewModelSwingWorkerExecutor executor)

initialize

public void initialize()

retrieveStateAsync

protected void retrieveStateAsync()

getStateFromRpc

protected EventStreamState getStateFromRpc()

setEventStreamState

protected void setEventStreamState(EventStreamState state)

addListener

public void addListener(EventStreamStateTrackerListener listener)

removeListener

public void removeListener(EventStreamStateTrackerListener listener)

dispose

public void dispose()

Specified by:

dispose in interface Disposable