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)
| 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. |
| 51 | pub 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 | } |
no test coverage detected