Add Reader webidl files

Author: wusyong

components/script/dom/bindings/codegen/CodegenRust.py

@@ -949,7 +949,7 @@ def wrapObjectTemplate(templateBody, nullValue, isDefinitelyObject, type,
 
         if failureCode is None:
             unwrapFailureCode = '''throw_type_error(*cx, "This object is not \
-                    an instance of ReadableStream.");\n'''
+                    an instance of ReadableStream.");\nreturn false;\n'''
         else:
             unwrapFailureCode = failureCode
 
@@ -958,7 +958,7 @@ def wrapObjectTemplate(templateBody, nullValue, isDefinitelyObject, type,
             {
                 use crate::realms::{AlreadyInRealm, InRealm};
                 let in_realm_proof = AlreadyInRealm::assert_for_cx(cx);
-                match ReadableStream::from_js(cx, $${val}.get().to_object(), InRealm::Already(&in_realm_proof)) {
+                match dom::readablestream::ReadableStream::from_js(cx, $${val}.get().to_object(), InRealm::Already(&in_realm_proof)) {
                     Ok(val) => val,
                     Err(()) => {
                     $*{failureCode}
@@ -973,7 +973,7 @@ def wrapObjectTemplate(templateBody, nullValue, isDefinitelyObject, type,
         templateBody = wrapObjectTemplate(templateBody, "None",
                                           isDefinitelyObject, type, failureCode)
 
-        declType = CGGeneric("DomRoot<ReadableStream>")
+        declType = CGGeneric("DomRoot<dom::readablestream::ReadableStream>")
 
         return handleOptional(templateBody, declType,
                               handleDefault("None"))

components/script/dom/mod.rs

@@ -509,8 +509,10 @@ pub mod range;
 pub mod raredata;
 pub mod readablebytestreamcontroller;
 pub mod readablestream;
+pub mod readablestreambyobreader;
 pub mod readablestreambyobrequest;
 pub mod readablestreamdefaultcontroller;
+pub mod readablestreamdefaultreader;
 pub mod request;
 pub mod resizeobserver;
 pub mod resizeobserverentry;

components/script/dom/readablestreambyobreader.rs

@@ -0,0 +1,72 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+use dom_struct::dom_struct;
+use js::jsapi::{
+    AutoRequireNoGC, HandleObject, HandleValue, Heap, IsReadableStream, JSContext, JSObject,
+};
+use js::jsval::{JSVal, ObjectValue, UndefinedValue};
+use js::rust::{HandleObject as SafeHandleObject, HandleValue as SafeHandleValue, IntoHandle};
+
+use crate::dom::bindings::codegen::Bindings::ReadableStreamBYOBReaderBinding::ReadableStreamBYOBReaderMethods;
+use crate::dom::bindings::conversions::{ConversionBehavior, ConversionResult};
+use crate::dom::bindings::error::Error;
+use crate::dom::bindings::import::module::Fallible;
+use crate::dom::bindings::reflector::{reflect_dom_object, DomObject, Reflector};
+use crate::dom::bindings::root::DomRoot;
+use crate::dom::bindings::settings_stack::{AutoEntryScript, AutoIncumbentScript};
+use crate::dom::bindings::utils::get_dictionary_property;
+use crate::dom::globalscope::GlobalScope;
+use crate::dom::promise::Promise;
+use crate::dom::readablestream::ReadableStream;
+use crate::js::conversions::FromJSValConvertible;
+use crate::realms::{enter_realm, InRealm};
+use crate::script_runtime::JSContext as SafeJSContext;
+
+#[dom_struct]
+pub struct ReadableStreamBYOBReader {
+    reflector_: Reflector,
+}
+
+impl ReadableStreamBYOBReader {
+    #[allow(non_snake_case)]
+    pub fn Constructor(
+        global: &GlobalScope,
+        proto: Option<SafeHandleObject>,
+        stream: DomRoot<ReadableStream>,
+    ) -> Fallible<DomRoot<Self>> {
+        todo!()
+    }
+
+    fn new_inherited() -> ReadableStreamBYOBReader {
+        ReadableStreamBYOBReader {
+            reflector_: Reflector::new(),
+        }
+    }
+
+    fn new(global: &GlobalScope) -> DomRoot<ReadableStreamBYOBReader> {
+        reflect_dom_object(Box::new(ReadableStreamBYOBReader::new_inherited()), global)
+    }
+}
+
+impl ReadableStreamBYOBReaderMethods for ReadableStreamBYOBReader {
+    fn Read(
+        &self,
+        view: js::gc::CustomAutoRooterGuard<js::typedarray::ArrayBufferView>,
+    ) -> std::rc::Rc<Promise> {
+        todo!()
+    }
+
+    fn ReleaseLock(&self) -> Fallible<()> {
+        todo!()
+    }
+
+    fn Closed(&self) -> std::rc::Rc<Promise> {
+        todo!()
+    }
+
+    fn Cancel(&self, cx: SafeJSContext, reason: SafeHandleValue) -> std::rc::Rc<Promise> {
+        todo!()
+    }
+}

components/script/dom/readablestreamdefaultreader.rs

@@ -0,0 +1,72 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+use dom_struct::dom_struct;
+use js::jsapi::{
+    AutoRequireNoGC, HandleObject, HandleValue, Heap, IsReadableStream, JSContext, JSObject,
+};
+use js::jsval::{JSVal, ObjectValue, UndefinedValue};
+use js::rust::{HandleObject as SafeHandleObject, HandleValue as SafeHandleValue, IntoHandle};
+
+use crate::dom::bindings::codegen::Bindings::ReadableStreamDefaultReaderBinding::ReadableStreamDefaultReaderMethods;
+use crate::dom::bindings::conversions::{ConversionBehavior, ConversionResult};
+use crate::dom::bindings::error::Error;
+use crate::dom::bindings::import::module::Fallible;
+use crate::dom::bindings::reflector::{reflect_dom_object, DomObject, Reflector};
+use crate::dom::bindings::root::DomRoot;
+use crate::dom::bindings::settings_stack::{AutoEntryScript, AutoIncumbentScript};
+use crate::dom::bindings::utils::get_dictionary_property;
+use crate::dom::globalscope::GlobalScope;
+use crate::dom::promise::Promise;
+use crate::dom::readablestream::ReadableStream;
+use crate::js::conversions::FromJSValConvertible;
+use crate::realms::{enter_realm, InRealm};
+use crate::script_runtime::JSContext as SafeJSContext;
+
+#[dom_struct]
+pub struct ReadableStreamDefaultReader {
+    reflector_: Reflector,
+}
+
+impl ReadableStreamDefaultReader {
+    #[allow(non_snake_case)]
+    pub fn Constructor(
+        global: &GlobalScope,
+        proto: Option<SafeHandleObject>,
+        stream: DomRoot<ReadableStream>,
+    ) -> Fallible<DomRoot<Self>> {
+        todo!()
+    }
+
+    fn new_inherited() -> ReadableStreamDefaultReader {
+        ReadableStreamDefaultReader {
+            reflector_: Reflector::new(),
+        }
+    }
+
+    fn new(global: &GlobalScope) -> DomRoot<ReadableStreamDefaultReader> {
+        reflect_dom_object(
+            Box::new(ReadableStreamDefaultReader::new_inherited()),
+            global,
+        )
+    }
+}
+
+impl ReadableStreamDefaultReaderMethods for ReadableStreamDefaultReader {
+    fn Read(&self) -> std::rc::Rc<Promise> {
+        todo!()
+    }
+
+    fn ReleaseLock(&self) -> Fallible<()> {
+        todo!()
+    }
+
+    fn Closed(&self) -> std::rc::Rc<Promise> {
+        todo!()
+    }
+
+    fn Cancel(&self, cx: SafeJSContext, reason: SafeHandleValue) -> std::rc::Rc<Promise> {
+        todo!()
+    }
+}

components/script/dom/webidls/ReadableStream.webidl

@@ -4,7 +4,7 @@
 
 // https://streams.spec.whatwg.org/#readablestream
 
-[Exposed=(Window,Worker)]
+[Exposed=*]
 interface _ReadableStream {
     [Throws]
     constructor(optional object underlyingSource, optional QueuingStrategy strategy = {});

components/script/dom/webidls/ReadableStreamBYOBReader.webidl

@@ -0,0 +1,18 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
+
+// https://streams.spec.whatwg.org/#byob-reader-class-definition
+
+[Exposed=*]
+interface ReadableStreamBYOBReader {
+  [Throws]
+  constructor(ReadableStream stream);
+
+  [NewObject]
+  Promise<ReadableStreamReadResult> read(ArrayBufferView view);
+
+  [Throws]
+  undefined releaseLock();
+};
+ReadableStreamBYOBReader includes ReadableStreamGenericReader;

components/script/dom/webidls/ReadableStreamDefaultReader.webidl

@@ -0,0 +1,34 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
+
+// https://streams.spec.whatwg.org/#generic-reader-mixin-definition
+// https://streams.spec.whatwg.org/#default-reader-class-definition
+
+typedef (ReadableStreamDefaultReader or ReadableStreamBYOBReader) ReadableStreamReader;
+
+interface mixin ReadableStreamGenericReader {
+  readonly attribute Promise<undefined> closed;
+
+  [NewObject]
+  Promise<undefined> cancel(optional any reason);
+};
+
+[Exposed=*]
+interface ReadableStreamDefaultReader {
+  [Throws]
+  constructor(ReadableStream stream);
+
+  [NewObject]
+  Promise<ReadableStreamReadResult> read();
+
+  [Throws]
+  undefined releaseLock();
+};
+ReadableStreamDefaultReader includes ReadableStreamGenericReader;
+
+
+dictionary ReadableStreamReadResult {
+ any value;
+ boolean done;
+};