diff options
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.cc | 18 |
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); } |