Struct worker::Queue

pub struct Queue(/* private fields */);

Implementations

impl Queue

pub async fn send<T, U: Into<SendMessage<T>>>(&self, message: U) -> Result<()>

where T: Serialize,

Sends a message to the Queue.

Accepts a struct that is serializable.

If message options are needed use the MessageBuilder to create the message.

Example

#[derive(Serialize)]
pub struct MyMessage {
    my_data: u32,
}

queue.send(MyMessage{ my_data: 1}).await?;

pub async fn send_raw<T: Into<SendMessage<JsValue>>>( &self, message: T ) -> Result<()>

Sends a raw JsValue to the Queue.

Use the RawMessageBuilder to create the message.

pub async fn send_batch<T: Serialize, U: Into<BatchSendMessage<T>>>( &self, messages: U ) -> Result<()>

Sends a batch of messages to the Queue.

Accepts an iterator that produces structs that are serializable.

If message options are needed use the BatchMessageBuilder to create the batch.

Example

#[derive(Serialize)]
pub struct MyMessage {
    my_data: u32,
}

queue.send_batch(vec![MyMessage{ my_data: 1}]).await?;

pub async fn send_raw_batch<T: Into<BatchSendMessage<JsValue>>>( &self, messages: T ) -> Result<()>

Sends a batch of raw messages to the Queue.

Accepts an iterator that produces structs that are serializable.

If message options are needed use the BatchMessageBuilder to create the batch.

Trait Implementations

impl AsRef<JsValue> for Queue

fn as_ref(&self) -> &JsValue

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for Queue

fn clone(&self) -> Queue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl EnvBinding for Queue

const TYPE_NAME: &'static str = "WorkerQueue"

fn get(val: JsValue) -> Result<Self>

impl From<Queue> for JsValue

fn from(queue: Queue) -> Self

Converts to this type from the input type.

impl JsCast for Queue

fn instanceof(val: &JsValue) -> bool

Performs a dynamic instanceof check to see whether the JsValue provided is an instance of this type.

fn unchecked_from_js(val: JsValue) -> Self

Performs a zero-cost unchecked conversion from a JsValue into an instance of Self

fn unchecked_from_js_ref(val: &JsValue) -> &Self

Performs a zero-cost unchecked conversion from a &JsValue into an instance of &Self.

fn has_type<T>(&self) -> bool

where T: JsCast,

Test whether this JS value has a type T.

fn dyn_into<T>(self) -> Result<T, Self>

where T: JsCast,

Performs a dynamic cast (checked at runtime) of this value into the target type T.

fn dyn_ref<T>(&self) -> Option<&T>

where T: JsCast,

Performs a dynamic cast (checked at runtime) of this value into the target type T.

fn unchecked_into<T>(self) -> T

where T: JsCast,

Performs a zero-cost unchecked cast into the specified type.

fn unchecked_ref<T>(&self) -> &T

where T: JsCast,

Performs a zero-cost unchecked cast into a reference to the specified type.

fn is_instance_of<T>(&self) -> bool

where T: JsCast,

Test whether this JS value is an instance of the type T.

fn is_type_of(val: &JsValue) -> bool

Performs a dynamic check to see whether the JsValue provided is a value of this type.

impl Send for Queue

impl Sync for Queue