(String key, Collection<Pair<String, String>> value)
| 85 | boolean warned = false; |
| 86 | long prevTick = RunLoop.tick; |
| 87 | |
| 88 | @Override |
| 89 | protected void send(String key, Collection<Pair<String, String>> value) { |
| 90 | |
| 91 | // if (value.size() == 0) return; |
| 92 | |
| 93 | int index = 0; |
| 94 | for (Pair<String, String> v : value) { |
| 95 | System.out.println(" --> " + v.second); |
| 96 | server.send(socketName, "_messageBus.publish('" + key + "', " + v.second + ")"); |
| 97 | if (index++ > 4) { |
| 98 | System.out.println(" limit exceeded (" + value.size() + ")"); |
| 99 | //TODO, notify... |
| 100 | break; |
| 101 | } |
| 102 | } |
| 103 | // } |
| 104 | } |
| 105 | }; |
| 106 |
no test coverage detected