diff options
author | Koushik Dutta <koushd@gmail.com> | 2013-05-27 19:29:16 -0700 |
---|---|---|
committer | Koushik Dutta <koushd@gmail.com> | 2013-05-27 19:29:16 -0700 |
commit | 381fbd9d34f7c199f6e3ffe93e49bd439149f815 (patch) | |
tree | 6cb6ab7c40fadea0dbf2b3e280f727c75f6d4735 /AndroidAsync/src/com/koushikdutta/async/parser | |
parent | 028dd67f21c49d40f48bc07bdc50eb08a7b4c02e (diff) | |
download | AndroidAsync-381fbd9d34f7c199f6e3ffe93e49bd439149f815.tar.gz AndroidAsync-381fbd9d34f7c199f6e3ffe93e49bd439149f815.tar.bz2 AndroidAsync-381fbd9d34f7c199f6e3ffe93e49bd439149f815.zip |
use emitter.close
Diffstat (limited to 'AndroidAsync/src/com/koushikdutta/async/parser')
-rw-r--r-- | AndroidAsync/src/com/koushikdutta/async/parser/ByteBufferListParser.java | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/AndroidAsync/src/com/koushikdutta/async/parser/ByteBufferListParser.java b/AndroidAsync/src/com/koushikdutta/async/parser/ByteBufferListParser.java index f4c1498..98b1a6d 100644 --- a/AndroidAsync/src/com/koushikdutta/async/parser/ByteBufferListParser.java +++ b/AndroidAsync/src/com/koushikdutta/async/parser/ByteBufferListParser.java @@ -2,8 +2,6 @@ package com.koushikdutta.async.parser; import com.koushikdutta.async.ByteBufferList; import com.koushikdutta.async.DataEmitter; -import com.koushikdutta.async.DataSink; -import com.koushikdutta.async.NullDataCallback; import com.koushikdutta.async.callback.CompletedCallback; import com.koushikdutta.async.callback.DataCallback; import com.koushikdutta.async.future.Future; @@ -19,10 +17,7 @@ public class ByteBufferListParser implements AsyncParser<ByteBufferList> { final SimpleFuture<ByteBufferList> ret = new SimpleFuture<ByteBufferList>() { @Override protected void cancelCleanup() { - emitter.pause(); - emitter.setDataCallback(new NullDataCallback()); - if (emitter instanceof DataSink) - ((DataSink)emitter).close(); + emitter.close(); } }; emitter.setDataCallback(new DataCallback() { |