Struct ReadableStreamDefaultReader

#[repr(C)]
pub(crate) struct ReadableStreamDefaultReader {
    reflector_: Reflector,
    stream: MutNullableDom<ReadableStream>,
    read_requests: DomRefCell<VecDeque<ReadRequest>>,
    closed_promise: DomRefCell<Rc<Promise>>,
}

https://streams.spec.whatwg.org/#readablestreamdefaultreader

Fields

reflector_: Reflector

stream: MutNullableDom<ReadableStream>

https://streams.spec.whatwg.org/#readablestreamgenericreader-stream

read_requests: DomRefCell<VecDeque<ReadRequest>>

closed_promise: DomRefCell<Rc<Promise>>

https://streams.spec.whatwg.org/#readablestreamgenericreader-closedpromise

Implementations

impl ReadableStreamDefaultReader

fn __assert_parent_type(&self)

impl ReadableStreamDefaultReader

fn new_with_proto( global: &GlobalScope, proto: Option<SafeHandleObject<'_>>, can_gc: CanGc, ) -> DomRoot<ReadableStreamDefaultReader>

fn new_inherited( global: &GlobalScope, can_gc: CanGc, ) -> ReadableStreamDefaultReader

pub(crate) fn new( global: &GlobalScope, can_gc: CanGc, ) -> DomRoot<ReadableStreamDefaultReader>

pub(crate) fn set_up( &self, stream: &ReadableStream, global: &GlobalScope, can_gc: CanGc, ) -> Fallible<()>

https://streams.spec.whatwg.org/#set-up-readable-stream-default-reader

pub(crate) fn close(&self, can_gc: CanGc)

https://streams.spec.whatwg.org/#readable-stream-close

pub(crate) fn add_read_request(&self, read_request: &ReadRequest)

https://streams.spec.whatwg.org/#readable-stream-add-read-request

pub(crate) fn get_num_read_requests(&self) -> usize

https://streams.spec.whatwg.org/#readable-stream-get-num-read-requests

pub(crate) fn error(&self, e: SafeHandleValue<'_>, can_gc: CanGc)

https://streams.spec.whatwg.org/#readable-stream-error

pub(crate) fn remove_read_request(&self) -> ReadRequest

The removal steps of https://streams.spec.whatwg.org/#readable-stream-fulfill-read-request

pub(crate) fn release(&self, can_gc: CanGc) -> Fallible<()>

https://streams.spec.whatwg.org/#abstract-opdef-readablestreamdefaultreaderrelease

fn take_read_requests(&self) -> VecDeque<ReadRequest>

fn error_read_requests(&self, rval: SafeHandleValue<'_>, can_gc: CanGc)

https://streams.spec.whatwg.org/#abstract-opdef-readablestreamdefaultreadererrorreadrequests

pub(crate) fn read( &self, cx: SafeJSContext, read_request: &ReadRequest, can_gc: CanGc, )

https://streams.spec.whatwg.org/#readable-stream-default-reader-read

pub(crate) 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, )

https://streams.spec.whatwg.org/#ref-for-readablestreamgenericreader-closedpromise%E2%91%A1

pub(crate) fn read_all_bytes( &self, cx: SafeJSContext, global: &GlobalScope, success_steps: Rc<dyn Fn(&[u8])>, failure_steps: Rc<dyn Fn(JSContext, HandleValue<'_>)>, realm: InRealm<'_>, can_gc: CanGc, )

https://streams.spec.whatwg.org/#readablestreamdefaultreader-read-all-bytes

pub(crate) fn process_read_requests( &self, cx: SafeJSContext, controller: DomRoot<ReadableByteStreamController>, can_gc: CanGc, ) -> Fallible<()>

step 3 of https://streams.spec.whatwg.org/#abstract-opdef-readablebytestreamcontrollerprocessreadrequestsusingqueue

Trait Implementations

impl DomObject for ReadableStreamDefaultReader

fn reflector(&self) -> &Reflector

Returns the receiver’s reflector.

impl DomObjectWrap<DomTypeHolder> for ReadableStreamDefaultReader

const WRAP: unsafe fn(_: SafeJSContext, _: &GlobalScope, _: Option<HandleObject<'_>>, _: Box<Self>, _: CanGc) -> Root<Dom<Self>> = {dom::bindings::codegen::GenericBindings::ReadableStreamDefaultReaderBinding::ReadableStreamDefaultReader_Binding::Wrap::<dom::bindings::codegen::DomTypeHolder::DomTypeHolder> as for<'a, 'b> unsafe fn(script_bindings::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_bindings::script_runtime::CanGc) -> script_bindings::root::Root<script_bindings::root::Dom<dom::readablestreamdefaultreader::ReadableStreamDefaultReader>>}

Function pointer to the general wrap function type

impl HasParent for ReadableStreamDefaultReader

fn as_parent(&self) -> &Reflector

This is used in a type assertion to ensure that the source and webidls agree as to what the parent type is

type Parent = Reflector

impl IDLInterface for ReadableStreamDefaultReader

fn derives(class: &'static DOMClass) -> bool

Returns whether the given DOM class derives that interface.

impl MallocSizeOf for ReadableStreamDefaultReader

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.

impl MutDomObject for ReadableStreamDefaultReader

unsafe fn init_reflector(&self, obj: *mut JSObject)

Initializes the Reflector

impl PartialEq for ReadableStreamDefaultReader

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl ReadableStreamDefaultReaderMethods<DomTypeHolder> for ReadableStreamDefaultReader

fn Constructor( global: &GlobalScope, proto: Option<SafeHandleObject<'_>>, can_gc: CanGc, stream: &ReadableStream, ) -> Fallible<DomRoot<Self>>

https://streams.spec.whatwg.org/#default-reader-constructor

fn Read(&self, can_gc: CanGc) -> Rc<Promise>

https://streams.spec.whatwg.org/#default-reader-read

fn ReleaseLock(&self, can_gc: CanGc) -> Fallible<()>

https://streams.spec.whatwg.org/#default-reader-release-lock

fn Closed(&self) -> Rc<Promise>

https://streams.spec.whatwg.org/#generic-reader-closed

fn Cancel( &self, _cx: SafeJSContext, reason: SafeHandleValue<'_>, can_gc: CanGc, ) -> Rc<Promise>

https://streams.spec.whatwg.org/#generic-reader-cancel

impl ReadableStreamGenericReader for ReadableStreamDefaultReader

fn get_closed_promise(&self) -> Rc<Promise>

fn set_closed_promise(&self, promise: Rc<Promise>)

fn set_stream(&self, stream: Option<&ReadableStream>)

fn get_stream(&self) -> Option<DomRoot<ReadableStream>>

fn as_default_reader(&self) -> Option<&ReadableStreamDefaultReader>

fn generic_initialize( &self, global: &GlobalScope, stream: &ReadableStream, can_gc: CanGc, )

https://streams.spec.whatwg.org/#readable-stream-reader-generic-initialize

fn reader_generic_cancel( &self, reason: SafeHandleValue<'_>, can_gc: CanGc, ) -> Rc<Promise>

https://streams.spec.whatwg.org/#readable-stream-reader-generic-cancel

fn generic_release(&self, can_gc: CanGc) -> Fallible<()>

https://streams.spec.whatwg.org/#readable-stream-reader-generic-release

fn closed(&self) -> Rc<Promise>

https://streams.spec.whatwg.org/#generic-reader-closed

fn generic_cancel( &self, global: &GlobalScope, reason: SafeHandleValue<'_>, can_gc: CanGc, ) -> Rc<Promise>

fn as_byob_reader(&self) -> Option<&ReadableStreamBYOBReader>

impl ToJSValConvertible for ReadableStreamDefaultReader

unsafe fn to_jsval(&self, cx: *mut JSContext, rval: MutableHandleValue<'_>)

Convert self to a JSVal. JSAPI failure causes a panic.

impl Traceable for ReadableStreamDefaultReader

unsafe fn trace(&self, tracer: *mut JSTracer)

Trace self.

impl Eq for ReadableStreamDefaultReader