summaryrefslogtreecommitdiff
path: root/chromium/third_party/blink/renderer/core/streams/writable_stream.cc
diff options
context:
space:
mode:
Diffstat (limited to 'chromium/third_party/blink/renderer/core/streams/writable_stream.cc')
-rw-r--r--chromium/third_party/blink/renderer/core/streams/writable_stream.cc18
1 files changed, 17 insertions, 1 deletions
diff --git a/chromium/third_party/blink/renderer/core/streams/writable_stream.cc b/chromium/third_party/blink/renderer/core/streams/writable_stream.cc
index da3db6e90c5..f0817bf8400 100644
--- a/chromium/third_party/blink/renderer/core/streams/writable_stream.cc
+++ b/chromium/third_party/blink/renderer/core/streams/writable_stream.cc
@@ -53,11 +53,27 @@ WritableStream* WritableStream::Create(ScriptState* script_state,
return stream;
}
+WritableStream* WritableStream::CreateWithCountQueueingStrategy(
+ ScriptState* script_state,
+ UnderlyingSinkBase* underlying_sink,
+ size_t high_water_mark) {
+ if (RuntimeEnabledFeatures::StreamsNativeEnabled()) {
+ return WritableStreamNative::CreateWithCountQueueingStrategy(
+ script_state, underlying_sink, high_water_mark);
+ }
+
+ return WritableStreamWrapper::CreateWithCountQueueingStrategy(
+ script_state, underlying_sink, high_water_mark);
+}
+
// static
WritableStream* WritableStream::Deserialize(ScriptState* script_state,
MessagePort* port,
ExceptionState& exception_state) {
- // TODO(ricea): Switch on Blink feature.
+ if (RuntimeEnabledFeatures::StreamsNativeEnabled()) {
+ return WritableStreamNative::Deserialize(script_state, port,
+ exception_state);
+ }
return WritableStreamWrapper::Deserialize(script_state, port,
exception_state);
}