rqjs-cli 0.1.1

rqjs-cli
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
36
37
38
39
40
41
42
43
44
45
46

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0
use rquickjs::{prelude::This, Class, Ctx, IntoJs, Result, Value};
use std::result::Result as StdResult;
use tokio::sync::broadcast::error::RecvError;

use crate::modules::events::Emitter;

use self::{readable::DefaultReadableStream, writable::DefaultWritableStream};

pub mod readable;
pub mod writable;

pub fn set_destroyed_and_error<'js>(
    is_destroyed: &mut bool,
    error_value: &mut Option<Value<'js>>,
    error: StdResult<Option<Value<'js>>, RecvError>,
) {
    *is_destroyed = true;
    if let Ok(error) = error {
        *error_value = error
    }
}
const DEFAULT_BUFFER_SIZE: usize = 1024 * 16;

pub trait SteamEvents<'js>
where
    Self: Emitter<'js>,
{
    fn emit_close(this: Class<'js, Self>, ctx: &Ctx<'js>, had_error: bool) -> Result<()> {
        Self::emit_str(
            This(this),
            ctx,
            "close",
            vec![had_error.into_js(ctx)?],
            false,
        )
    }

    #[allow(dead_code)]
    fn emit_end(this: Class<'js, Self>, ctx: &Ctx<'js>) -> Result<()> {
        Self::emit_str(This(this), ctx, "end", vec![], false)
    }
}

impl_stream_events!(DefaultReadableStream, DefaultWritableStream);