worker_plus_sys/
queue.rs

1use js_sys::{Array, Promise};
2use wasm_bindgen::prelude::*;
3
4#[wasm_bindgen]
5extern "C" {
6    #[wasm_bindgen(extends=::js_sys::Object, js_name=MessageBatch)]
7    #[derive(Debug, Clone, PartialEq, Eq)]
8    pub type MessageBatch;
9
10    #[wasm_bindgen(method, getter,  js_class=MessageBatch, js_name=queue)]
11    pub fn queue(this: &MessageBatch) -> String;
12
13    #[wasm_bindgen(method, getter, js_class=MessageBatch, js_name=messages)]
14    pub fn messages(this: &MessageBatch) -> Array;
15
16    #[wasm_bindgen(structural, method, js_class=MessageBatch, js_name=retryAll)]
17    pub fn retry_all(this: &MessageBatch);
18}
19
20#[wasm_bindgen]
21extern "C" {
22    #[wasm_bindgen (extends = ::js_sys::Object, js_name = Queue)]
23    #[derive(Debug, Clone, PartialEq, Eq)]
24    pub type Queue;
25
26    #[wasm_bindgen(structural, method, js_class=Queue, js_name=send)]
27    pub fn send(this: &Queue, mesage: JsValue) -> Promise;
28}
worker_plus_sys/queue.rs

worker_plus_sys/
queue.rs
