#[repr(C)]pub struct ReadableStreamDefaultController {
reflector_: Reflector,
queue: RefCell<QueueWithSizes>,
underlying_source: MutNullableDom<UnderlyingSourceContainer>,
stream: MutNullableDom<ReadableStream>,
strategy_hwm: f64,
strategy_size: RefCell<Option<Rc<QueuingStrategySize>>>,
close_requested: Cell<bool>,
started: Cell<bool>,
pulling: Cell<bool>,
pull_again: Cell<bool>,
}Expand description
Fields§
§reflector_: Reflector§queue: RefCell<QueueWithSizes>§underlying_source: MutNullableDom<UnderlyingSourceContainer>A mutable reference to the underlying source is used to implement these two internal slots:
https://streams.spec.whatwg.org/#readablestreamdefaultcontroller-pullalgorithm https://streams.spec.whatwg.org/#readablestreamdefaultcontroller-cancelalgorithm
stream: MutNullableDom<ReadableStream>§strategy_hwm: f64§strategy_size: RefCell<Option<Rc<QueuingStrategySize>>>§close_requested: Cell<bool>§started: Cell<bool>§pulling: Cell<bool>§pull_again: Cell<bool>Implementations§
source§impl ReadableStreamDefaultController
impl ReadableStreamDefaultController
fn new_inherited( global: &GlobalScope, underlying_source_type: UnderlyingSourceType, strategy_hwm: f64, strategy_size: Rc<QueuingStrategySize>, can_gc: CanGc, ) -> ReadableStreamDefaultController
pub fn new( global: &GlobalScope, underlying_source: UnderlyingSourceType, strategy_hwm: f64, strategy_size: Rc<QueuingStrategySize>, can_gc: CanGc, ) -> Root<Dom<ReadableStreamDefaultController>>
sourcepub fn set_underlying_source_this_object(&self, this_object: HandleObject<'_>)
pub fn set_underlying_source_this_object(&self, this_object: HandleObject<'_>)
Setting the JS object after the heap has settled down.
sourcefn should_call_pull(&self) -> bool
fn should_call_pull(&self) -> bool
sourcefn call_pull_if_needed(&self, can_gc: CanGc)
fn call_pull_if_needed(&self, can_gc: CanGc)
sourcepub fn perform_cancel_steps(
&self,
reason: SafeHandleValue<'_>,
can_gc: CanGc,
) -> Rc<Promise>
pub fn perform_cancel_steps( &self, reason: SafeHandleValue<'_>, can_gc: CanGc, ) -> Rc<Promise>
sourcepub fn perform_pull_steps(&self, read_request: &ReadRequest, can_gc: CanGc)
pub fn perform_pull_steps(&self, read_request: &ReadRequest, can_gc: CanGc)
sourcepub fn perform_release_steps(&self)
pub fn perform_release_steps(&self)
sourcepub fn enqueue(
&self,
cx: SafeJSContext,
chunk: SafeHandleValue<'_>,
can_gc: CanGc,
) -> Result<(), Error>
pub fn enqueue( &self, cx: SafeJSContext, chunk: SafeHandleValue<'_>, can_gc: CanGc, ) -> Result<(), Error>
sourcepub fn enqueue_native(&self, chunk: Vec<u8>)
pub fn enqueue_native(&self, chunk: Vec<u8>)
sourcepub fn get_in_memory_bytes(&self) -> Option<Vec<u8>>
pub fn get_in_memory_bytes(&self) -> Option<Vec<u8>>
Return bytes synchronously if the stream has all data in memory.
sourcefn clear_algorithms(&self)
fn clear_algorithms(&self)
sourcefn get_desired_size(&self) -> Option<f64>
fn get_desired_size(&self) -> Option<f64>
sourcefn can_close_or_enqueue(&self) -> bool
fn can_close_or_enqueue(&self) -> bool
Trait Implementations§
source§impl DomObjectWrap for ReadableStreamDefaultController
impl DomObjectWrap for ReadableStreamDefaultController
source§const WRAP: unsafe fn(_: SafeJSContext, _: &GlobalScope, _: Option<HandleObject<'_>>, _: Box<Self>, _: CanGc) -> Root<Dom<Self>> = {dom::bindings::codegen::Bindings::ReadableStreamDefaultControllerBinding::ReadableStreamDefaultController_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::readablestreamdefaultcontroller::ReadableStreamDefaultController>, script_runtime::CanGc) -> dom::bindings::root::Root<dom::bindings::root::Dom<dom::readablestreamdefaultcontroller::ReadableStreamDefaultController>>}
const WRAP: unsafe fn(_: SafeJSContext, _: &GlobalScope, _: Option<HandleObject<'_>>, _: Box<Self>, _: CanGc) -> Root<Dom<Self>> = {dom::bindings::codegen::Bindings::ReadableStreamDefaultControllerBinding::ReadableStreamDefaultController_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::readablestreamdefaultcontroller::ReadableStreamDefaultController>, script_runtime::CanGc) -> dom::bindings::root::Root<dom::bindings::root::Dom<dom::readablestreamdefaultcontroller::ReadableStreamDefaultController>>}
Function pointer to the general wrap function type
source§impl MallocSizeOf for ReadableStreamDefaultController
impl MallocSizeOf for ReadableStreamDefaultController
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 ReadableStreamDefaultControllerMethods<DomTypeHolder> for ReadableStreamDefaultController
impl ReadableStreamDefaultControllerMethods<DomTypeHolder> for ReadableStreamDefaultController
impl Eq for ReadableStreamDefaultController
Auto Trait Implementations§
impl !Freeze for ReadableStreamDefaultController
impl !RefUnwindSafe for ReadableStreamDefaultController
impl !Send for ReadableStreamDefaultController
impl !Sync for ReadableStreamDefaultController
impl Unpin for ReadableStreamDefaultController
impl !UnwindSafe for ReadableStreamDefaultController
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