add top-level sendPing method to connections

This commit is contained in:
Zlatin Balevsky
2018-07-27 07:43:59 +01:00
parent e167d16ab2
commit 3e02161b7d
2 changed files with 19 additions and 2 deletions

View File

@@ -95,4 +95,11 @@ abstract class Connection implements Closeable {
}
protected abstract void write(def message);
void sendPing() {
def ping = [:]
ping.type = "Ping"
ping.version = 1
messages.put(ping)
}
}

View File

@@ -27,8 +27,18 @@ class UltrapeerConnection extends Connection {
@Override
protected void write(Object message) {
// TODO Auto-generated method stub
if (message instanceof Map) {
writeJsonMessage(message)
} else {
writeBinaryMessage(message)
}
}
private void writeJsonMessage(def message) {
}
private void writeBinaryMessage(def message) {
}
}