Change data pipe wrappers used by SerialConnection to use message pipe.

extensions/renderer/api/serial/data_receiver_unittest.cc

 // Copyright 2014 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 <queue>
 
 #include "device/serial/data_source_sender.h"
 #include "device/serial/data_stream.mojom.h"
 #include "extensions/renderer/api_test_base.h"
 #include "grit/extensions_renderer_resources.h"
@@ skipping 45 matching lines @@
     std::string data;
     int32_t error = 0;
     if (!data_to_send_.empty()) {
       data = data_to_send_.front();
       data_to_send_.pop();
     }
     if (!error_to_send_.empty()) {
       error = error_to_send_.front();
       error_to_send_.pop();
     }
-    if (error == 2) {
-      sender_->ShutDown();
-      sender_ = NULL;
-      return;
-    }
     DCHECK(buffer->GetSize() >= static_cast<uint32_t>(data.size()));
     memcpy(buffer->GetData(), data.c_str(), data.size());
     if (error)
       buffer->DoneWithError(data.size(), error);
     else
       buffer->Done(data.size());
   }
 
   scoped_refptr<device::DataSourceSender> sender_;
 
@@ skipping 48 matching lines @@
 TEST_F(DataReceiverTest, SerializeDuringReceive) {
   data_to_send_.push("a");
   RunTest("data_receiver_unittest.js", "testSerializeDuringReceive");
 }
 
 TEST_F(DataReceiverTest, SerializeAfterClose) {
   data_to_send_.push("a");
   RunTest("data_receiver_unittest.js", "testSerializeAfterClose");
 }
 
-TEST_F(DataReceiverTest, SourceShutdown) {
-  error_to_send_.push(2);
-  RunTest("data_receiver_unittest.js", "testSourceShutdown");
-}
-
 }  // namespace extensions