#[repr(C)]pub struct ReadableStreamDefaultReader {
reflector_: Reflector,
stream: MutNullableDom<ReadableStream>,
read_requests: DomRefCell<VecDeque<ReadRequest>>,
closed_promise: DomRefCell<Rc<Promise>>,
}
Expand description
Fields§
§reflector_: Reflector
§stream: MutNullableDom<ReadableStream>
§read_requests: DomRefCell<VecDeque<ReadRequest>>
§closed_promise: DomRefCell<Rc<Promise>>
Implementations§
source§impl ReadableStreamDefaultReader
impl ReadableStreamDefaultReader
fn __assert_parent_type(&self)
source§impl ReadableStreamDefaultReader
impl ReadableStreamDefaultReader
sourcepub fn Constructor(
global: &GlobalScope,
proto: Option<SafeHandleObject<'_>>,
can_gc: CanGc,
stream: &ReadableStream,
) -> Result<Root<Dom<Self>>, Error>
pub fn Constructor( global: &GlobalScope, proto: Option<SafeHandleObject<'_>>, can_gc: CanGc, stream: &ReadableStream, ) -> Result<Root<Dom<Self>>, Error>
fn new_with_proto( global: &GlobalScope, proto: Option<SafeHandleObject<'_>>, can_gc: CanGc, ) -> Root<Dom<ReadableStreamDefaultReader>>
pub fn new_inherited( global: &GlobalScope, can_gc: CanGc, ) -> ReadableStreamDefaultReader
sourcepub fn set_up(
&self,
stream: &ReadableStream,
global: &GlobalScope,
can_gc: CanGc,
) -> Result<(), Error>
pub fn set_up( &self, stream: &ReadableStream, global: &GlobalScope, can_gc: CanGc, ) -> Result<(), Error>
sourcepub fn generic_initialize(
&self,
global: &GlobalScope,
stream: &ReadableStream,
can_gc: CanGc,
) -> Result<(), Error>
pub fn generic_initialize( &self, global: &GlobalScope, stream: &ReadableStream, can_gc: CanGc, ) -> Result<(), Error>
sourcepub fn add_read_request(&self, read_request: &ReadRequest)
pub fn add_read_request(&self, read_request: &ReadRequest)
sourcepub fn get_num_read_requests(&self) -> usize
pub fn get_num_read_requests(&self) -> usize
sourcepub fn error(&self, e: SafeHandleValue<'_>)
pub fn error(&self, e: SafeHandleValue<'_>)
sourcepub fn remove_read_request(&self) -> ReadRequest
pub fn remove_read_request(&self) -> ReadRequest
The removal steps of https://streams.spec.whatwg.org/#readable-stream-fulfill-read-request
sourcepub fn generic_release(&self)
pub fn generic_release(&self)
fn take_read_requests(&self) -> VecDeque<ReadRequest>
sourcefn generic_cancel(
&self,
reason: SafeHandleValue<'_>,
can_gc: CanGc,
) -> Rc<Promise>
fn generic_cancel( &self, reason: SafeHandleValue<'_>, can_gc: CanGc, ) -> Rc<Promise>
sourcefn error_read_requests(&self, rval: SafeHandleValue<'_>)
fn error_read_requests(&self, rval: SafeHandleValue<'_>)
sourcepub fn read(&self, read_request: &ReadRequest, can_gc: CanGc)
pub fn read(&self, read_request: &ReadRequest, can_gc: CanGc)
sourcepub fn append_native_handler_to_closed_promise(
&self,
branch_1: &ReadableStream,
branch_2: &ReadableStream,
canceled_1: Rc<Cell<bool>>,
canceled_2: Rc<Cell<bool>>,
cancel_promise: Rc<Promise>,
can_gc: CanGc,
)
pub fn append_native_handler_to_closed_promise( &self, branch_1: &ReadableStream, branch_2: &ReadableStream, canceled_1: Rc<Cell<bool>>, canceled_2: Rc<Cell<bool>>, cancel_promise: Rc<Promise>, can_gc: CanGc, )
Trait Implementations§
source§impl DomObjectWrap for ReadableStreamDefaultReader
impl DomObjectWrap for ReadableStreamDefaultReader
source§const WRAP: unsafe fn(_: SafeJSContext, _: &GlobalScope, _: Option<HandleObject<'_>>, _: Box<Self>, _: CanGc) -> Root<Dom<Self>> = {dom::bindings::codegen::Bindings::ReadableStreamDefaultReaderBinding::ReadableStreamDefaultReader_Binding::Wrap as for<'a, 'b> unsafe fn(script_runtime::JSContext, &'a dom::globalscope::GlobalScope, std::option::Option<js::rust::Handle<'b, *mut js::jsapi::JSObject>>, std::boxed::Box<dom::readablestreamdefaultreader::ReadableStreamDefaultReader>, script_runtime::CanGc) -> dom::bindings::root::Root<dom::bindings::root::Dom<dom::readablestreamdefaultreader::ReadableStreamDefaultReader>>}
const WRAP: unsafe fn(_: SafeJSContext, _: &GlobalScope, _: Option<HandleObject<'_>>, _: Box<Self>, _: CanGc) -> Root<Dom<Self>> = {dom::bindings::codegen::Bindings::ReadableStreamDefaultReaderBinding::ReadableStreamDefaultReader_Binding::Wrap as for<'a, 'b> unsafe fn(script_runtime::JSContext, &'a dom::globalscope::GlobalScope, std::option::Option<js::rust::Handle<'b, *mut js::jsapi::JSObject>>, std::boxed::Box<dom::readablestreamdefaultreader::ReadableStreamDefaultReader>, script_runtime::CanGc) -> dom::bindings::root::Root<dom::bindings::root::Dom<dom::readablestreamdefaultreader::ReadableStreamDefaultReader>>}
Function pointer to the general wrap function type
source§impl MallocSizeOf for ReadableStreamDefaultReader
impl MallocSizeOf for ReadableStreamDefaultReader
source§fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize
fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize
Measure the heap usage of all descendant heap-allocated structures, but
not the space taken up by the value itself.
source§impl ReadableStreamDefaultReaderMethods<DomTypeHolder> for ReadableStreamDefaultReader
impl ReadableStreamDefaultReaderMethods<DomTypeHolder> for ReadableStreamDefaultReader
source§fn Constructor(
global: &GlobalScope,
proto: Option<SafeHandleObject<'_>>,
can_gc: CanGc,
stream: &ReadableStream,
) -> Result<Root<Dom<Self>>, Error>
fn Constructor( global: &GlobalScope, proto: Option<SafeHandleObject<'_>>, can_gc: CanGc, stream: &ReadableStream, ) -> Result<Root<Dom<Self>>, Error>
source§fn Cancel(
&self,
_cx: SafeJSContext,
reason: SafeHandleValue<'_>,
can_gc: CanGc,
) -> Rc<Promise>
fn Cancel( &self, _cx: SafeJSContext, reason: SafeHandleValue<'_>, can_gc: CanGc, ) -> Rc<Promise>
impl Eq for ReadableStreamDefaultReader
Auto Trait Implementations§
impl !Freeze for ReadableStreamDefaultReader
impl !RefUnwindSafe for ReadableStreamDefaultReader
impl !Send for ReadableStreamDefaultReader
impl !Sync for ReadableStreamDefaultReader
impl Unpin for ReadableStreamDefaultReader
impl !UnwindSafe for ReadableStreamDefaultReader
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.source§impl<T> Filterable for T
impl<T> Filterable for T
source§fn filterable(
self,
filter_name: &'static str,
) -> RequestFilterDataProvider<T, fn(_: DataRequest<'_>) -> bool>
fn filterable( self, filter_name: &'static str, ) -> RequestFilterDataProvider<T, fn(_: DataRequest<'_>) -> bool>
Creates a filterable data provider with the given name for debugging. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<T> MaybeBoxed<Box<T>> for T
impl<T> MaybeBoxed<Box<T>> for T
source§fn maybe_boxed(self) -> Box<T>
fn maybe_boxed(self) -> Box<T>
Convert
source§impl<T> MaybeBoxed<T> for T
impl<T> MaybeBoxed<T> for T
source§fn maybe_boxed(self) -> T
fn maybe_boxed(self) -> T
Convert