WebSocket Pepper API: SRPC proxy implementation

ppapi/tests/test_websocket.cc

 // Copyright (c) 2012 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 "ppapi/tests/test_websocket.h"
 
 #include <string.h>
 #include <vector>
 
 #include "ppapi/c/dev/ppb_testing_dev.h"
@@ skipping 231 matching lines @@
     CreateVarString("x-test"),
     CreateVarString("x-test")
   };
   PP_Var good_protocols[] = {
     CreateVarString("x-test"),
     CreateVarString("x-yatest")
   };
 
   PP_Resource ws = websocket_interface_->Create(instance_->pp_instance());
   ASSERT_TRUE(ws);
+  TestCompletionCallback callback(instance_->pp_instance(), force_async_);
   int32_t result = websocket_interface_->Connect(
-      ws, url, bad_protocols, 2U, PP_BlockUntilComplete());
+      ws, url, bad_protocols, 2U,
+      static_cast<pp::CompletionCallback>(callback).pp_completion_callback());
+  if (result == PP_OK_COMPLETIONPENDING)
+    result = callback.WaitForResult();
   ASSERT_EQ(PP_ERROR_BADARGUMENT, result);
   core_interface_->ReleaseResource(ws);
 
   ws = websocket_interface_->Create(instance_->pp_instance());
   ASSERT_TRUE(ws);
   result = websocket_interface_->Connect(
       ws, url, good_protocols, 2U, PP_BlockUntilComplete());
   ASSERT_EQ(PP_ERROR_BLOCKS_MAIN_THREAD, result);
   core_interface_->ReleaseResource(ws);
 
@@ skipping 355 matching lines @@
   ASSERT_TRUE(AreEqualWithString(ws.GetCloseReason().pp_var(), reason.c_str()));
   ASSERT_EQ(true, ws.GetCloseWasClean());
   ASSERT_TRUE(AreEqualWithString(ws.GetExtensions().pp_var(), ""));
   ASSERT_TRUE(AreEqualWithString(ws.GetProtocol().pp_var(), ""));
   ASSERT_EQ(PP_WEBSOCKETREADYSTATE_CLOSED_DEV, ws.GetReadyState());
   ASSERT_TRUE(AreEqualWithString(ws.GetURL().pp_var(), kCloseServerURL));
   ASSERT_EQ(PP_WEBSOCKETBINARYTYPE_ARRAYBUFFER_DEV, ws.GetBinaryType());
 
   PASS();
 }