ferrijs-std 0.2.4

Node and web standard library for the ferrijs QuickJS runtime: WHATWG Streams, Events, AbortController, Buffer, crypto, fs, os, url, zlib and the capability model they enforce (partly derived from awslabs/llrt, Apache-2.0).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use rquickjs::{Function, Object, Result};

use crate::stream_web::{readable::stream::ReadableStreamType, utils::ValueOrUndefined};

#[derive(Default)]
pub(crate) struct UnderlyingSource<'js> {
    // callback UnderlyingSourceStartCallback = any (ReadableStreamController controller);
    pub(crate) start: Option<Function<'js>>,
    // callback UnderlyingSourcePullCallback = Promise<undefined> (ReadableStreamController controller);
    pub(crate) pull: Option<Function<'js>>,
    // callback UnderlyingSourceCancelCallback = Promise<undefined> (optional any reason);
    pub(crate) cancel: Option<Function<'js>>,
    pub(super) r#type: Option<ReadableStreamType>,
    // [EnforceRange] unsigned long long autoAllocateChunkSize;
    pub(crate) auto_allocate_chunk_size: Option<usize>,
}

impl<'js> UnderlyingSource<'js> {
    pub(super) fn from_object(obj: Object<'js>) -> Result<Self> {
        let start = obj.get_value_or_undefined::<_, _>("start")?;
        let pull = obj.get_value_or_undefined::<_, _>("pull")?;
        let cancel = obj.get_value_or_undefined::<_, _>("cancel")?;
        let r#type = obj.get_value_or_undefined::<_, _>("type")?;
        let auto_allocate_chunk_size =
            obj.get_value_or_undefined::<_, _>("autoAllocateChunkSize")?;

        Ok(Self {
            start,
            pull,
            cancel,
            r#type,
            auto_allocate_chunk_size,
        })
    }
}