MCPcopy Create free account
hub / github.com/Wulf/create-rust-app / create_async_queue

Function create_async_queue

crates/create-rust-app/src/tasks/mod.rs:51–59  ·  view source on GitHub ↗

Creates a new async queue with the specified max pool size. You should not need to use this function directly. Instead, use `async_queue()` to get a reference to the queue. This function is public because it is used by the `async_queue` binary in generated projects. You can also use it to create a separate async queue bin for your own purposes. For example, to support a different async task type.

(max_pool_size: u32)

Source from the content-addressed store, hash-verified

49/// You can also use it to create a separate async queue bin for your own purposes.
50/// For example, to support a different async task type.
51pub fn create_async_queue(max_pool_size: u32) -> AsyncQueue<NoTls> {
52 #[cfg(debug_assertions)]
53 crate::load_env_vars();
54
55 AsyncQueue::builder()
56 .uri(Database::connection_url())
57 .max_pool_size(max_pool_size)
58 .build()
59}

Callers 2

async_queueFunction · 0.85
mainFunction · 0.85

Calls 1

load_env_varsFunction · 0.85

Tested by

no test coverage detected