diff options
Diffstat (limited to 'remoting/protocol/stream_reader.h')
-rw-r--r-- | remoting/protocol/stream_reader.h | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/remoting/protocol/stream_reader.h b/remoting/protocol/stream_reader.h deleted file mode 100644 index 7f8e004..0000000 --- a/remoting/protocol/stream_reader.h +++ /dev/null @@ -1,66 +0,0 @@ -// Copyright (c) 2010 The Chromium Authors. All rights reserved. -// Use of this source code is governed by a BSD-style license that can be -// found in the LICENSE file. - -#ifndef REMOTING_PROTOCOL_STREAM_READER_H_ -#define REMOTING_PROTOCOL_STREAM_READER_H_ - -#include "base/callback.h" -#include "base/scoped_ptr.h" -#include "remoting/protocol/socket_reader_base.h" - -namespace remoting { - -class EventStreamReader : public SocketReaderBase { - public: - EventStreamReader(); - ~EventStreamReader(); - - // The OnMessageCallback is called whenever a new message is received. - // Ownership of the message is passed the callback. - typedef Callback1<ChromotingClientMessage*>::Type OnMessageCallback; - - // Initialize the reader and start reading. Must be called on the thread - // |socket| belongs to. The callback will be called when a new message is - // received. EventStreamReader owns |on_message_callback|, doesn't own - // |socket|. - void Init(net::Socket* socket, OnMessageCallback* on_message_callback); - - protected: - virtual void OnDataReceived(net::IOBuffer* buffer, int data_size); - - private: - MessagesDecoder messages_decoder_; - scoped_ptr<OnMessageCallback> on_message_callback_; - - DISALLOW_COPY_AND_ASSIGN(EventStreamReader); -}; - -class VideoStreamReader : public SocketReaderBase { - public: - VideoStreamReader(); - ~VideoStreamReader(); - - // The OnMessageCallback is called whenever a new message is received. - // Ownership of the message is passed the callback. - typedef Callback1<ChromotingHostMessage*>::Type OnMessageCallback; - - // Initialize the reader and start reading. Must be called on the thread - // |socket| belongs to. The callback will be called when a new message is - // received. VideoStreamReader owns |on_message_callback|, doesn't own - // |socket|. - void Init(net::Socket* socket, OnMessageCallback* on_message_callback); - - protected: - virtual void OnDataReceived(net::IOBuffer* buffer, int data_size); - - private: - MessagesDecoder messages_decoder_; - scoped_ptr<OnMessageCallback> on_message_callback_; - - DISALLOW_COPY_AND_ASSIGN(VideoStreamReader); -}; - -} // namespace remoting - -#endif // REMOTING_PROTOCOL_STREAM_READER_H_ |