diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/Connection.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/Connection.java
index e25e4707cd96c249a5d481b32a5dfb96a32e2e0c..2885c12f9518a3c36d54fd4469bcb98ad54ea2a7 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/Connection.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/Connection.java
@@ -89,7 +89,7 @@ class Connection {
     private final AtomicLong _lifetimeDupMessageReceived = new AtomicLong();
     
     public static final long MAX_RESEND_DELAY = 45*1000;
-    public static final long MIN_RESEND_DELAY = 750;
+    public static final long MIN_RESEND_DELAY = 100;
 
     /**
      *  Wait up to 5 minutes after disconnection so we can ack/close packets.
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionOptions.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionOptions.java
index 51e8b5312c4fd65fd44345b815d44117f829f417..b6e1bc3657d1adc96dbe7e006f95ef54817b2839 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionOptions.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionOptions.java
@@ -129,7 +129,8 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
     static final int INITIAL_WINDOW_SIZE = 6;
     static final int DEFAULT_MAX_SENDS = 8;
     public static final int DEFAULT_INITIAL_RTT = 8*1000;    
-    public static final int DEFAULT_INITIAL_ACK_DELAY = 1000;  
+    private static final int MAX_RTT = 60*1000;    
+    private static final int DEFAULT_INITIAL_ACK_DELAY = 750;  
     static final int MIN_WINDOW_SIZE = 1;
     private static final boolean DEFAULT_ANSWER_PINGS = true;
     private static final int DEFAULT_INACTIVITY_TIMEOUT = 90*1000;
@@ -559,8 +560,8 @@ class ConnectionOptions extends I2PSocketOptionsImpl {
         
         synchronized(this) {
             _rtt = ms; 
-            if (_rtt > 60*1000)
-                _rtt = 60*1000;
+            if (_rtt > MAX_RTT)
+                _rtt = MAX_RTT;
         }
     }
 
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionPacketHandler.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionPacketHandler.java
index cb1dcaf3221744704962cf3c96d80d4aee622e38..4b8c498103bc39d09563209f4cdb514778057c45 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionPacketHandler.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionPacketHandler.java
@@ -107,7 +107,7 @@ class ConnectionPacketHandler {
             // Here, for the purposes of calculating whether the input stream is full,
             // we assume all the not-ready blocks are the max message size.
             // This prevents us from getting DoSed by accepting unlimited out-of-order small messages
-            long ready = con.getInputStream().getHighestReadyBockId();
+            long ready = con.getInputStream().getHighestReadyBlockId();
             int available = con.getOptions().getInboundBufferSize() - con.getInputStream().getTotalReadySize();
             int allowedBlocks = available/con.getOptions().getMaxMessageSize();
             if (seqNum > ready + allowedBlocks) {
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/MessageInputStream.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/MessageInputStream.java
index b8ea9a0a24e26aa3bf4df6c4924d16185ab8aa66..ea0c33c34f8f45422f7f61b1f4dbe53879e99ec0 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/MessageInputStream.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/MessageInputStream.java
@@ -74,7 +74,7 @@ class MessageInputStream extends InputStream {
     /** What is the highest block ID we've completely received through?
      * @return highest data block ID completely received or -1 for none
      */
-    public long getHighestReadyBockId() { 
+    public long getHighestReadyBlockId() { 
         synchronized (_dataLock) {
             return _highestReadyBlockId; 
         }
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/PcapWriter.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/PcapWriter.java
index 754ebf28a5ef970288fd89142aa584a820f336a0..9a3c3e0be4006c3a9c868d476ff2fd7b5e988e6c 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/PcapWriter.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/PcapWriter.java
@@ -272,7 +272,7 @@ public class PcapWriter {
                 // TODO just use a recent high unackedIn count?
                 // following is from ConnectionPacketHandler
                 // this is not interesting, we have lots of buffers
-                long ready = con.getInputStream().getHighestReadyBockId();
+                long ready = con.getInputStream().getHighestReadyBlockId();
                 int available = con.getOptions().getInboundBufferSize() - con.getInputStream().getTotalReadySize();
                 int allowedBlocks = available/con.getOptions().getMaxMessageSize();
                 window = (ready + allowedBlocks) - pkt.getSequenceNum();