From 381fbd9d34f7c199f6e3ffe93e49bd439149f815 Mon Sep 17 00:00:00 2001
From: Koushik Dutta <koushd@gmail.com>
Date: Mon, 27 May 2013 19:29:16 -0700
Subject: use emitter.close

---
 .../src/com/koushikdutta/async/parser/ByteBufferListParser.java    | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

(limited to 'AndroidAsync/src/com/koushikdutta/async/parser')

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() {
-- 
cgit v1.2.3