Add Reader's 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,70 @@
+/* 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 std::rc::Rc;
+
+use dom_struct::dom_struct;
+use js::rust::{HandleObject as SafeHandleObject, HandleValue as SafeHandleValue};
+
+use crate::dom::bindings::codegen::Bindings::ReadableStreamBYOBReaderBinding::ReadableStreamBYOBReaderMethods;
+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::globalscope::GlobalScope;
+use crate::dom::promise::Promise;
+use crate::dom::readablestream::ReadableStream;
+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
+        Err(Error::NotFound)
+    }
+
+    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>,
+    ) -> Rc<Promise> {
+        // TODO
+        Promise::new(&self.reflector_.global())
+    }
+
+    fn ReleaseLock(&self) -> Fallible<()> {
+        // TODO
+        Err(Error::NotFound)
+    }
+
+    fn Closed(&self) -> Rc<Promise> {
+        // TODO
+        Promise::new(&self.reflector_.global())
+    }
+
+    fn Cancel(&self, _cx: SafeJSContext, _reason: SafeHandleValue) -> Rc<Promise> {
+        // TODO
+        Promise::new(&self.reflector_.global())
+    }
+}

components/script/dom/readablestreamdefaultreader.rs

@@ -0,0 +1,70 @@
+/* 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 std::rc::Rc;
+
+use dom_struct::dom_struct;
+use js::rust::{HandleObject as SafeHandleObject, HandleValue as SafeHandleValue};
+
+use crate::dom::bindings::codegen::Bindings::ReadableStreamDefaultReaderBinding::ReadableStreamDefaultReaderMethods;
+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::globalscope::GlobalScope;
+use crate::dom::promise::Promise;
+use crate::dom::readablestream::ReadableStream;
+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
+        Err(Error::NotFound)
+    }
+
+    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) -> Rc<Promise> {
+        // TODO
+        Promise::new(&self.reflector_.global())
+    }
+
+    fn ReleaseLock(&self) -> Fallible<()> {
+        // TODO
+        Err(Error::NotFound)
+    }
+
+    fn Closed(&self) -> Rc<Promise> {
+        // TODO
+        Promise::new(&self.reflector_.global())
+    }
+
+    fn Cancel(&self, _cx: SafeJSContext, _reason: SafeHandleValue) -> Rc<Promise> {
+        // TODO
+        Promise::new(&self.reflector_.global())
+    }
+}

components/script/dom/webidls/ReadableStreamBYOBReader.webidl

@@ -0,0 +1,19 @@
+/* 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,35 @@
+/* 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;
+};
+