jstime_core 0.66.0

Another JS Runtime
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
47
48
49
50
51
52
53
54
55
56
57

pub(crate) fn get_external_references() -> Vec<v8::ExternalReference> {
    vec![
        v8::ExternalReference {
            function: v8::MapFnTo::map_fn_to(streams_enqueue_chunk),
        },
        v8::ExternalReference {
            function: v8::MapFnTo::map_fn_to(streams_close_stream),
        },
        v8::ExternalReference {
            function: v8::MapFnTo::map_fn_to(streams_error_stream),
        },
    ]
}

pub(crate) fn register_bindings(scope: &mut v8::PinScope, bindings: v8::Local<v8::Object>) {
    let name = v8::String::new(scope, "streamsEnqueueChunk").unwrap();
    let value = v8::Function::new(scope, streams_enqueue_chunk).unwrap();
    bindings.set(scope, name.into(), value.into());

    let name = v8::String::new(scope, "streamsCloseStream").unwrap();
    let value = v8::Function::new(scope, streams_close_stream).unwrap();
    bindings.set(scope, name.into(), value.into());

    let name = v8::String::new(scope, "streamsErrorStream").unwrap();
    let value = v8::Function::new(scope, streams_error_stream).unwrap();
    bindings.set(scope, name.into(), value.into());
}

// Placeholder function for enqueuing chunks
fn streams_enqueue_chunk(
    _scope: &mut v8::PinScope,
    _args: v8::FunctionCallbackArguments,
    _rv: v8::ReturnValue,
) {
    // This is a placeholder - actual implementation would involve
    // managing stream state and queuing chunks
}

// Placeholder function for closing stream
fn streams_close_stream(
    _scope: &mut v8::PinScope,
    _args: v8::FunctionCallbackArguments,
    _rv: v8::ReturnValue,
) {
    // This is a placeholder - actual implementation would involve
    // managing stream state
}

// Placeholder function for erroring stream
fn streams_error_stream(
    _scope: &mut v8::PinScope,
    _args: v8::FunctionCallbackArguments,
    _rv: v8::ReturnValue,
) {
    // This is a placeholder - actual implementation would involve
    // managing stream state and error handling
}