Index: blimp/net/blimp_connection.cc |
diff --git a/blimp/net/blimp_connection.cc b/blimp/net/blimp_connection.cc |
index 792d0943730b7d7f2e20bf3865e1d352637a4039..e8f3c68cc376131814ccd41bcf308c8950a2ce91 100644 |
--- a/blimp/net/blimp_connection.cc |
+++ b/blimp/net/blimp_connection.cc |
@@ -20,6 +20,7 @@ |
#include "net/base/completion_callback.h" |
namespace blimp { |
+namespace { |
// Forwards incoming blimp messages to PacketWriter. |
class BlimpMessageSender : public BlimpMessageProcessor { |
@@ -96,6 +97,8 @@ |
} |
} |
+} // namespace |
+ |
BlimpConnection::BlimpConnection(std::unique_ptr<PacketReader> reader, |
std::unique_ptr<PacketWriter> writer) |
: reader_(std::move(reader)), |
@@ -107,7 +110,9 @@ |
// Observe the connection errors received by any of this connection's network |
// objects. |
message_pump_->set_error_observer(this); |
- outgoing_msg_processor_->set_error_observer(this); |
+ BlimpMessageSender* sender = |
+ static_cast<BlimpMessageSender*>(outgoing_msg_processor_.get()); |
+ sender->set_error_observer(this); |
} |
BlimpConnection::BlimpConnection() {} |