summaryrefslogtreecommitdiffstats
path: root/simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java
diff options
context:
space:
mode:
authormikaelpeltier <mikaelpeltier@google.com>2015-06-24 14:31:11 +0200
committerMikael Peltier <mikaelpeltier@google.com>2015-06-24 14:59:36 +0000
commit04563874ddaac702d6c715eaa89c29b253f4c54e (patch)
treec305fa98670c3e80be494cc054a8e31b51bfe7f2 /simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java
parentf1828481ebcfee3bddc323fca178a4502a60ceef (diff)
downloadtoolchain_jack-04563874ddaac702d6c715eaa89c29b253f4c54e.tar.gz
toolchain_jack-04563874ddaac702d6c715eaa89c29b253f4c54e.tar.bz2
toolchain_jack-04563874ddaac702d6c715eaa89c29b253f4c54e.zip
Add simpleframework source files
Change-Id: I18d01df16de2868ca5458f79a88e6070b75db2c3 (cherry picked from commit 3e9f84cf7b22f6970eb8041ca38d12d75c6bb270)
Diffstat (limited to 'simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java')
-rw-r--r--simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java33
1 files changed, 33 insertions, 0 deletions
diff --git a/simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java b/simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java
new file mode 100644
index 00000000..5f09efa2
--- /dev/null
+++ b/simple/simple-http/src/test/java/org/simpleframework/http/socket/table/WebSocketTableSweeper.java
@@ -0,0 +1,33 @@
+package org.simpleframework.http.socket.table;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public class WebSocketTableSweeper {
+
+ private final WebSocketTable table;
+
+ public WebSocketTableSweeper(WebSocketTable table) {
+ this.table = table;
+ }
+
+ public Map<WebSocketTableUpdateType, String> sweep(long time, long count) {
+ Map<WebSocketTableUpdateType, String> messages = new LinkedHashMap<WebSocketTableUpdateType, String>();
+
+ if(count <= 1) {
+ WebSocketTableSchema schema = table.getSchema();
+ String schemaUpdate = schema.createStyle();
+ messages.put(WebSocketTableUpdateType.SCHEMA, schemaUpdate);
+ }
+ String highlightUpdate = table.calculateHighlight(time);
+ String deltaUpdate = table.calculateChange(time);// really should only take small batches...
+
+ highlightUpdate = count + "@" + System.currentTimeMillis() + ":" + highlightUpdate;
+ deltaUpdate = count + "@" + System.currentTimeMillis() + ":" + deltaUpdate;
+
+ messages.put(WebSocketTableUpdateType.HIGHLIGHT, highlightUpdate);
+ messages.put(WebSocketTableUpdateType.DELTA, deltaUpdate);
+
+ return messages;
+ }
+}