runicast: reuse buffer between receive()'s

2 files changed, 4 insertions, 2 deletions

diff --git a/src/main/java/derms/net/runicast/Receive.java b/src/main/java/derms/net/runicast/Receive.java
index 8620ebd..88008bd 100644
--- a/src/main/java/derms/net/runicast/Receive.java
+++ b/src/main/java/derms/net/runicast/Receive.java
@@ -28,8 +28,9 @@ class Receive<T extends MessagePayload> implements Runnable {
 
     @Override
     public void run() {
+        ByteBuffer buf = ByteBuffer.allocate(bufSize);
         for (;;) {
-            ByteBuffer buf = ByteBuffer.allocate(bufSize);
+            buf.clear();
             try {
                 SocketAddress sender = sock.receive(buf);
                 Message<T> msg = (Message<T>) Serial.decode(buf, Message.class);
diff --git a/src/main/java/derms/net/runicast/ReceiveAcks.java b/src/main/java/derms/net/runicast/ReceiveAcks.java
index 9d7b7de..e2c7e3c 100644
--- a/src/main/java/derms/net/runicast/ReceiveAcks.java
+++ b/src/main/java/derms/net/runicast/ReceiveAcks.java
@@ -29,8 +29,9 @@ class ReceiveAcks<T extends MessagePayload> implements Runnable {
 
     @Override
     public void run() {
+        ByteBuffer buf = ByteBuffer.allocate(bufSize);
         for (;;) {
-            ByteBuffer buf = ByteBuffer.allocate(bufSize);
+            buf.clear();
             try {
                 sock.receive(buf);
                 Ack ack = Serial.decode(buf, Ack.class);