aboutsummaryrefslogtreecommitdiffstats
path: root/AndroidAsync/src/com/koushikdutta/async/Util.java
diff options
context:
space:
mode:
Diffstat (limited to 'AndroidAsync/src/com/koushikdutta/async/Util.java')
-rw-r--r--AndroidAsync/src/com/koushikdutta/async/Util.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/AndroidAsync/src/com/koushikdutta/async/Util.java b/AndroidAsync/src/com/koushikdutta/async/Util.java
index d9808ae..e8b88fa 100644
--- a/AndroidAsync/src/com/koushikdutta/async/Util.java
+++ b/AndroidAsync/src/com/koushikdutta/async/Util.java
@@ -15,6 +15,7 @@ import java.io.InputStream;
import java.nio.ByteBuffer;
public class Util {
+ static boolean SUPRESS_DEBUG_EXCEPTIONS = false;
public static void emitAllData(DataEmitter emitter, ByteBufferList list) {
int remaining;
DataCallback handler = null;
@@ -32,6 +33,9 @@ public class Util {
// System.out.println("Data: " + list.peekString());
System.out.println("handler: " + handler);
+ list.recycle();
+ if (SUPRESS_DEBUG_EXCEPTIONS)
+ return;
assert false;
throw new RuntimeException("mDataHandler failed to consume data, yet remains the mDataHandler.");
}
@@ -43,6 +47,9 @@ public class Util {
// System.out.println("Data: " + list.peekString());
System.out.println("handler: " + handler);
System.out.println("emitter: " + emitter);
+ list.recycle();
+ if (SUPRESS_DEBUG_EXCEPTIONS)
+ return;
assert false;
throw new RuntimeException("Not all data was consumed by Util.emitAllData");
}