Index: remoting/protocol/message_reader.h |
diff --git a/remoting/protocol/message_reader.h b/remoting/protocol/message_reader.h |
index 20da39e04b903f971df5eb202d72151266d079ef..4192b12a5caa6c98ac5d3d33ccd324fe65fb0f1f 100644 |
--- a/remoting/protocol/message_reader.h |
+++ b/remoting/protocol/message_reader.h |
@@ -35,7 +35,7 @@ class P2PStreamSocket; |
// e.g. when we the sender sends multiple messages in one TCP packet. |
class MessageReader : public base::NonThreadSafe { |
public: |
- typedef base::Callback<void(scoped_ptr<CompoundBuffer>, const base::Closure&)> |
+ typedef base::Callback<void(scoped_ptr<CompoundBuffer> message)> |
MessageReceivedCallback; |
typedef base::Callback<void(int)> ReadFailedCallback; |
@@ -55,7 +55,6 @@ class MessageReader : public base::NonThreadSafe { |
void HandleReadResult(int result, bool* read_succeeded); |
void OnDataReceived(net::IOBuffer* data, int data_size); |
void RunCallback(scoped_ptr<CompoundBuffer> message); |
- void OnMessageDone(); |
ReadFailedCallback read_failed_callback_; |
@@ -65,11 +64,6 @@ class MessageReader : public base::NonThreadSafe { |
// OnRead() to be called when new data is received. |
bool read_pending_; |
- // Number of messages that we received, but haven't finished |
- // processing yet, i.e. |done_task| hasn't been called for these |
- // messages. |
- int pending_messages_; |
- |
bool closed_; |
scoped_refptr<net::IOBuffer> read_buffer_; |