Lines Matching refs:MessageReader
25 // MessageReader reads data from the socket asynchronously and calls
30 // In order to throttle the stream, MessageReader doesn't try to read
36 class MessageReader : public base::NonThreadSafe {
41 MessageReader();
42 virtual ~MessageReader();
44 // Initialize the MessageReader with a socket. If a message is received
75 base::WeakPtrFactory<MessageReader> weak_factory_;
77 DISALLOW_COPY_AND_ASSIGN(MessageReader);
80 // Version of MessageReader for protocol buffer messages, that parses
97 message_reader_.reset(new MessageReader());
117 scoped_ptr<MessageReader> message_reader_;
