Enum PullAlgorithm 

pub enum PullAlgorithm<'js> {
    ReturnPromiseUndefined,
    Function {
        f: Function<'js>,
        underlying_source: Null<Undefined<Object<'js>>>,
    },
    RustFunction(Rc<Box<dyn Fn(Ctx<'js>, ReadableStreamControllerClass<'js>) -> Result<Promise<'js>> + 'js>>),
    Tee(Class<'js, TeeState<'js>>),
    Transform(Class<'js, TransformStream<'js>>),
}

Variants

ReturnPromiseUndefined

Function

Fields

f: Function<'js>

underlying_source: Null<Undefined<Object<'js>>>

RustFunction(Rc<Box<dyn Fn(Ctx<'js>, ReadableStreamControllerClass<'js>) -> Result<Promise<'js>> + 'js>>)

Tee(Class<'js, TeeState<'js>>)

Transform(Class<'js, TransformStream<'js>>)

Implementations

impl<'js> PullAlgorithm<'js>

pub fn from_fn( f: impl Fn(Ctx<'js>, ReadableStreamControllerClass<'js>) -> Result<Promise<'js>> + 'js, ) -> Self

pub fn from_fn_once( f: impl FnOnce(Ctx<'js>, ReadableStreamControllerClass<'js>) -> Result<Promise<'js>> + 'js, ) -> Self

Wrap a one-shot pull closure. Subsequent invocations after the first resolve with undefined without calling f again — useful for streams that enqueue their whole payload in one go and then close.

Trait Implementations

impl<'js> Clone for PullAlgorithm<'js>

fn clone(&self) -> PullAlgorithm<'js>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'js> JsLifetime<'js> for PullAlgorithm<'js>

type Changed<'to> = PullAlgorithm<'to>

The target which has the same type as a Self but with another lifetime 't

impl<'js> Trace<'js> for PullAlgorithm<'js>

fn trace<'a>(&self, tracer: Tracer<'a, 'js>)