Index: remoting/protocol/protobuf_message_parser.h |
diff --git a/remoting/protocol/protobuf_message_parser.h b/remoting/protocol/protobuf_message_parser.h |
index 4fe01916823374fbe97e0f5a4293706b68aa47a7..43f86f06012583465e2d1e98deefdf298a86e55d 100644 |
--- a/remoting/protocol/protobuf_message_parser.h |
+++ b/remoting/protocol/protobuf_message_parser.h |
@@ -23,8 +23,7 @@ class ProtobufMessageParser { |
public: |
// The callback that is called when a new message is received. |done_task| |
// must be called by the callback when it's done processing the |message|. |
- typedef typename base::Callback<void(scoped_ptr<T> message, |
- const base::Closure& done_task)> |
+ typedef typename base::Callback<void(scoped_ptr<T> message)> |
MessageReceivedCallback; |
// |message_reader| must outlive ProtobufMessageParser. |
@@ -41,8 +40,7 @@ class ProtobufMessageParser { |
} |
private: |
- void OnNewData(scoped_ptr<CompoundBuffer> buffer, |
- const base::Closure& done_task) { |
+ void OnNewData(scoped_ptr<CompoundBuffer> buffer) { |
scoped_ptr<T> message(new T()); |
CompoundBufferInputStream stream(buffer.get()); |
bool ret = message->ParseFromZeroCopyStream(&stream); |
@@ -50,7 +48,7 @@ class ProtobufMessageParser { |
LOG(WARNING) << "Received message that is not a valid protocol buffer."; |
} else { |
DCHECK_EQ(stream.position(), buffer->total_bytes()); |
- message_received_callback_.Run(std::move(message), done_task); |
+ message_received_callback_.Run(std::move(message)); |
} |
} |