aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/dom/readablestream.rs
diff options
context:
space:
mode:
authorJosh Matthews <josh@joshmatthews.net>2025-02-21 06:10:00 -0500
committerGitHub <noreply@github.com>2025-02-21 11:10:00 +0000
commit1192ae32b02ccb3803ae8e7e71a0e268a387046c (patch)
tree0e8a2fc1cb9da20e079d36ea706fe5c77c1f094e /components/script/dom/readablestream.rs
parent14db055d4618ccd232e04e9b35b3c3a49e3d6c3f (diff)
downloadservo-1192ae32b02ccb3803ae8e7e71a0e268a387046c.tar.gz
servo-1192ae32b02ccb3803ae8e7e71a0e268a387046c.zip
script: Refer to DOM interfaces with generic types in generated bindings. (#35457)
Signed-off-by: Josh Matthews <josh@joshmatthews.net>
Diffstat (limited to 'components/script/dom/readablestream.rs')
-rw-r--r--components/script/dom/readablestream.rs14
1 files changed, 7 insertions, 7 deletions
diff --git a/components/script/dom/readablestream.rs b/components/script/dom/readablestream.rs
index 1c1eceab0ba..019a290c96d 100644
--- a/components/script/dom/readablestream.rs
+++ b/components/script/dom/readablestream.rs
@@ -26,7 +26,7 @@ use crate::dom::bindings::codegen::Bindings::UnderlyingSourceBinding::Underlying
use crate::dom::bindings::conversions::{ConversionBehavior, ConversionResult};
use crate::dom::bindings::error::Error;
use crate::dom::bindings::import::module::Fallible;
-use crate::dom::bindings::import::module::UnionTypes::ReadableStreamDefaultReaderOrReadableStreamBYOBReader as ReadableStreamReader;
+use crate::dom::bindings::codegen::UnionTypes::ReadableStreamDefaultReaderOrReadableStreamBYOBReader as ReadableStreamReader;
use crate::dom::bindings::reflector::{DomGlobal, Reflector, reflect_dom_object_with_proto};
use crate::dom::bindings::root::{DomRoot, MutNullableDom, Dom};
use crate::dom::bindings::trace::RootedTraceableBox;
@@ -666,13 +666,13 @@ impl ReadableStream {
// If stream.[[state]] is "closed", return a promise resolved with undefined.
if self.is_closed() {
- let promise = Promise::new(&self.reflector_.global(), can_gc);
+ let promise = Promise::new(&self.global(), can_gc);
promise.resolve_native(&());
return promise;
}
// If stream.[[state]] is "errored", return a promise rejected with stream.[[storedError]].
if self.is_errored() {
- let promise = Promise::new(&self.reflector_.global(), can_gc);
+ let promise = Promise::new(&self.global(), can_gc);
unsafe {
let cx = GlobalScope::get_cx();
rooted!(in(*cx) let mut rval = UndefinedValue());
@@ -708,7 +708,7 @@ impl ReadableStream {
// Create a new promise,
// and setup a handler in order to react to the fulfillment of sourceCancelPromise.
- let global = self.reflector_.global();
+ let global = self.global();
let result_promise = Promise::new(&global, can_gc);
let fulfillment_handler = Box::new(SourceCancelPromiseFulfillmentHandler {
result: result_promise.clone(),
@@ -784,7 +784,7 @@ impl ReadableStream {
// Let reason2 be undefined.
let reason_2 = Rc::new(Heap::boxed(UndefinedValue()));
// Let cancelPromise be a new promise.
- let cancel_promise = Promise::new(&self.reflector_.global(), can_gc);
+ let cancel_promise = Promise::new(&self.global(), can_gc);
let tee_source_1 = DefaultTeeUnderlyingSource::new(
&reader,
@@ -824,7 +824,7 @@ impl ReadableStream {
// Set branch_1 to ! CreateReadableStream(startAlgorithm, pullAlgorithm, cancel1Algorithm).
let branch_1 = create_readable_stream(
- &self.reflector_.global(),
+ &self.global(),
underlying_source_type_branch_1,
QueuingStrategy::empty(),
can_gc,
@@ -834,7 +834,7 @@ impl ReadableStream {
// Set branch_2 to ! CreateReadableStream(startAlgorithm, pullAlgorithm, cancel2Algorithm).
let branch_2 = create_readable_stream(
- &self.reflector_.global(),
+ &self.global(),
underlying_source_type_branch_2,
QueuingStrategy::empty(),
can_gc,