Implement MAX_CONCURRENT_STREAMS SETTINGS header

net/spdy/spdy_http_stream_unittest.cc

 // Copyright (c) 2010 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 "net/spdy/spdy_http_stream.h"
 #include "base/ref_counted.h"
 #include "base/time.h"
 #include "net/base/mock_host_resolver.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_log.h"
@@ skipping 97 matching lines @@
 };
 
 // Needs fixing, see http://crbug.com/28622
 TEST_F(SpdyHttpStreamTest, SendRequest) {
   scoped_refptr<SpdySession> session(CreateSpdySession());
   HttpRequestInfo request;
   request.method = "GET";
   request.url = GURL("http://www.google.com/");
   TestCompletionCallback callback;
   HttpResponseInfo response;
-
-  scoped_refptr<SpdyStream> stream;
+  scoped_ptr<SpdyHttpStream> http_stream(new SpdyHttpStream());
   ASSERT_EQ(
       OK,
-      session->CreateStream(request.url, HIGHEST, &stream, BoundNetLog()));
-
-  scoped_ptr<SpdyHttpStream> http_stream(new SpdyHttpStream(stream.get()));
-  http_stream->InitializeRequest(request, base::Time::Now(), NULL);
+      http_stream->InitializeStream(session, request, BoundNetLog(), NULL));
+  http_stream->InitializeRequest(base::Time::Now(), NULL);
   EXPECT_EQ(ERR_IO_PENDING,
             http_stream->SendRequest(&response, &callback));
 
   // Need to manually remove the spdy session since normally it gets removed on
   // socket close/error, but we aren't communicating over a socket here.
   pool_peer_.RemoveSpdySession(session);
 }
 
 // TODO(willchan): Write a longer test for SpdyStream that exercises all
 // methods.
 
 }  // namespace
 
 }  // namespace net