Incorporate BlobChannel into Blimp image encode/decode pipeline.

blimp/net/blimp_connection_unittest.cc

 // Copyright 2015 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.
 
 #include "blimp/net/blimp_connection.h"
 
 #include <stddef.h>
 
 #include <string>
 
@@ skipping 140 matching lines @@
   EXPECT_CALL(*writer_,
               WritePacket(BufferEqualsProto(*CreateInputMessage()), _))
       .WillOnce(SaveArg<1>(&write_packet_cb))
       .RetiresOnSaturation();
   EXPECT_CALL(error_observer1_, OnConnectionError(net::ERR_FAILED))
       .WillOnce(testing::InvokeWithoutArgs(
           this, &BlimpConnectionTest::DropConnection));
 
   BlimpMessageProcessor* sender = connection_->GetOutgoingMessageProcessor();
   net::TestCompletionCallback complete_cb_1;
-  sender->ProcessMessage(CreateInputMessage(),
-                         complete_cb_1.callback());
+  sender->ProcessMessage(CreateInputMessage(), complete_cb_1.callback());
   base::ResetAndReturn(&write_packet_cb).Run(net::ERR_FAILED);
   EXPECT_EQ(net::ERR_FAILED, complete_cb_1.WaitForResult());
 }
 
 // Verifies that a ReadPacket error causes ErrorObservers to be notified.
 TEST_F(BlimpConnectionTest, ReadPacketErrorInvokesErrorObservers) {
   scoped_refptr<net::GrowableIOBuffer> read_packet_buffer;
   net::CompletionCallback read_packet_cb;
 
   EXPECT_CALL(*reader_, ReadPacket(_, _))
@@ skipping 47 matching lines @@
 
   // Put the EndConnection message in the buffer and invoke the read callback.
   read_packet_buffer->SetCapacity(message->ByteSize());
   ASSERT_TRUE(message->SerializeToArray(read_packet_buffer->data(),
                                         message->GetCachedSize()));
   base::ResetAndReturn(&read_packet_cb).Run(message->ByteSize());
 }
 
 }  // namespace
 }  // namespace blimp