Index: remoting/protocol/client_event_dispatcher.cc |
diff --git a/remoting/protocol/client_event_dispatcher.cc b/remoting/protocol/client_event_dispatcher.cc |
index 18e2d2d0bf6ed9fd1c4989af073ef1b260921398..31f766456199c23417d1bb001aa17cff3b02396b 100644 |
--- a/remoting/protocol/client_event_dispatcher.cc |
+++ b/remoting/protocol/client_event_dispatcher.cc |
@@ -20,13 +20,6 @@ ClientEventDispatcher::ClientEventDispatcher() |
} |
ClientEventDispatcher::~ClientEventDispatcher() { |
- writer_.Close(); |
-} |
- |
-void ClientEventDispatcher::OnInitialized() { |
- // TODO(garykac): Set write failed callback. |
- writer_.Init(channel(), |
- BufferedSocketWriter::WriteFailedCallback()); |
} |
void ClientEventDispatcher::InjectKeyEvent(const KeyEvent& event) { |
@@ -35,7 +28,7 @@ void ClientEventDispatcher::InjectKeyEvent(const KeyEvent& event) { |
EventMessage message; |
message.set_sequence_number(base::Time::Now().ToInternalValue()); |
message.mutable_key_event()->CopyFrom(event); |
- writer_.Write(SerializeAndFrameMessage(message), base::Closure()); |
+ writer()->Write(SerializeAndFrameMessage(message), base::Closure()); |
} |
void ClientEventDispatcher::InjectTextEvent(const TextEvent& event) { |
@@ -43,14 +36,14 @@ void ClientEventDispatcher::InjectTextEvent(const TextEvent& event) { |
EventMessage message; |
message.set_sequence_number(base::Time::Now().ToInternalValue()); |
message.mutable_text_event()->CopyFrom(event); |
- writer_.Write(SerializeAndFrameMessage(message), base::Closure()); |
+ writer()->Write(SerializeAndFrameMessage(message), base::Closure()); |
} |
void ClientEventDispatcher::InjectMouseEvent(const MouseEvent& event) { |
EventMessage message; |
message.set_sequence_number(base::Time::Now().ToInternalValue()); |
message.mutable_mouse_event()->CopyFrom(event); |
- writer_.Write(SerializeAndFrameMessage(message), base::Closure()); |
+ writer()->Write(SerializeAndFrameMessage(message), base::Closure()); |
} |
} // namespace protocol |