Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(669)

Side by Side Diff: Source/modules/fetch/BodyStreamBufferTest.cpp

Issue 1171913003: **** [WIP] Blink-side: Implement FetchBlobDataConsumerHandle **** (Closed) Base URL: https://chromium.googlesource.com/chromium/blink.git@master
Patch Set: Clean up. Created 5 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "config.h" 5 #include "config.h"
6 #include "modules/fetch/BodyStreamBuffer.h" 6 #include "modules/fetch/BodyStreamBuffer.h"
7 7
8 #include "core/dom/DOMArrayBuffer.h" 8 #include "core/dom/DOMArrayBuffer.h"
9 #include "core/dom/DOMException.h" 9 #include "core/dom/DOMException.h"
10 #include "core/dom/ExceptionCode.h" 10 #include "core/dom/ExceptionCode.h"
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after
138 buffer->close(); 138 buffer->close();
139 EXPECT_TRUE(buffer->isClosed()); 139 EXPECT_TRUE(buffer->isClosed());
140 EXPECT_EQ(2, observer1->writeCount()); 140 EXPECT_EQ(2, observer1->writeCount());
141 EXPECT_EQ(1, observer1->closeCount()); 141 EXPECT_EQ(1, observer1->closeCount());
142 EXPECT_EQ(0, observer1->errorCount()); 142 EXPECT_EQ(0, observer1->errorCount());
143 EXPECT_EQ(0, observer2->writeCount()); 143 EXPECT_EQ(0, observer2->writeCount());
144 EXPECT_EQ(0, observer2->closeCount()); 144 EXPECT_EQ(0, observer2->closeCount());
145 EXPECT_EQ(0, observer2->errorCount()); 145 EXPECT_EQ(0, observer2->errorCount());
146 } 146 }
147 147
148 /*
148 TEST(BodyStreamBufferTest, CreateBlob) 149 TEST(BodyStreamBufferTest, CreateBlob)
149 { 150 {
150 BodyStreamBuffer* buffer = new BodyStreamBuffer(new MockCanceller); 151 BodyStreamBuffer* buffer = new BodyStreamBuffer(new MockCanceller);
151 BlobHandleCallback* callback1 = new BlobHandleCallback(); 152 BlobHandleCallback* callback1 = new BlobHandleCallback();
152 BlobHandleCallback* callback2 = new BlobHandleCallback(); 153 BlobHandleCallback* callback2 = new BlobHandleCallback();
153 EXPECT_TRUE(buffer->readAllAndCreateBlobHandle("text/html", callback1)); 154 EXPECT_TRUE(buffer->readAllAndCreateBlobHandle("text/html", callback1));
154 EXPECT_FALSE(buffer->readAllAndCreateBlobHandle("text/html", callback2)); 155 EXPECT_FALSE(buffer->readAllAndCreateBlobHandle("text/html", callback2));
155 buffer->write(DOMArrayBuffer::create("foobar", 6)); 156 buffer->write(DOMArrayBuffer::create("foobar", 6));
156 EXPECT_FALSE(callback1->blobHandle()); 157 EXPECT_FALSE(callback1->blobHandle());
157 buffer->write(DOMArrayBuffer::create("piyo", 4)); 158 buffer->write(DOMArrayBuffer::create("piyo", 4));
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after
240 { 241 {
241 BodyStreamBuffer* buffer = new BodyStreamBuffer(new MockCanceller); 242 BodyStreamBuffer* buffer = new BodyStreamBuffer(new MockCanceller);
242 BlobHandleCallback* callback = new BlobHandleCallback(); 243 BlobHandleCallback* callback = new BlobHandleCallback();
243 buffer->write(DOMArrayBuffer::create("foobar", 6)); 244 buffer->write(DOMArrayBuffer::create("foobar", 6));
244 buffer->error(DOMException::create(NetworkError, "Error Message")); 245 buffer->error(DOMException::create(NetworkError, "Error Message"));
245 EXPECT_TRUE(buffer->readAllAndCreateBlobHandle("", callback)); 246 EXPECT_TRUE(buffer->readAllAndCreateBlobHandle("", callback));
246 EXPECT_TRUE(callback->exception()); 247 EXPECT_TRUE(callback->exception());
247 EXPECT_EQ("NetworkError", callback->exception()->name()); 248 EXPECT_EQ("NetworkError", callback->exception()->name());
248 EXPECT_EQ("Error Message", callback->exception()->message()); 249 EXPECT_EQ("Error Message", callback->exception()->message());
249 } 250 }
251 */
250 252
251 TEST(BodyStreamBufferTest, Cancel) 253 TEST(BodyStreamBufferTest, Cancel)
252 { 254 {
253 auto canceller = new MockCanceller; 255 auto canceller = new MockCanceller;
254 BodyStreamBuffer* buffer = new BodyStreamBuffer(canceller); 256 BodyStreamBuffer* buffer = new BodyStreamBuffer(canceller);
255 buffer->cancel(); 257 buffer->cancel();
256 258
257 EXPECT_EQ(1, canceller->counter()); 259 EXPECT_EQ(1, canceller->counter());
258 EXPECT_FALSE(buffer->isClosed()); 260 EXPECT_FALSE(buffer->isClosed());
259 EXPECT_FALSE(buffer->hasError()); 261 EXPECT_FALSE(buffer->hasError());
260 } 262 }
261 263
262 } // namespace blink 264 } // namespace blink
OLDNEW
« no previous file with comments | « Source/modules/fetch/BodyStreamBuffer.cpp ('k') | Source/modules/fetch/CompositeDataConsumerHandle.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698