@Metered
@Timed
public class DataStreamWebsocket
extends java.lang.Object
| Modifier and Type | Class | Description |
|---|---|---|
static class |
DataStreamWebsocket.DataAndInfoEncoder |
| Constructor | Description |
|---|---|
DataStreamWebsocket(SimulationStore simStore,
DataStreamStore dataStore,
com.fasterxml.jackson.databind.ObjectMapper mapper,
java.util.concurrent.ScheduledThreadPoolExecutor executor) |
| Modifier and Type | Method | Description |
|---|---|---|
void |
onClose(javax.websocket.Session session) |
|
void |
onError(javax.websocket.Session session,
java.lang.Throwable reason) |
|
void |
onOpen(javax.websocket.Session session,
java.lang.String simId,
java.lang.String dataId) |
@Inject public DataStreamWebsocket(SimulationStore simStore, DataStreamStore dataStore, com.fasterxml.jackson.databind.ObjectMapper mapper, java.util.concurrent.ScheduledThreadPoolExecutor executor)