mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-08-21 00:00:10 +02:00
fmt strikes again
This commit is contained in:
@@ -4,9 +4,9 @@
|
||||
//! compilation.
|
||||
|
||||
mod pool;
|
||||
pub(crate) use pool::{spawn_blocking, BlockingPool, Spawner};
|
||||
#[cfg(feature = "rt-multi-thread")]
|
||||
pub(crate) use pool::spawn_blocking_internal;
|
||||
pub(crate) use pool::{spawn_blocking, BlockingPool, Spawner};
|
||||
|
||||
cfg_fs! {
|
||||
pub(crate) use pool::spawn_mandatory_blocking;
|
||||
|
||||
@@ -196,7 +196,9 @@ where
|
||||
R: Send + 'static,
|
||||
{
|
||||
let rt = Handle::current();
|
||||
rt.inner.blocking_spawner().spawn_blocking_internal(&rt, func)
|
||||
rt.inner
|
||||
.blocking_spawner()
|
||||
.spawn_blocking_internal(&rt, func)
|
||||
}
|
||||
|
||||
cfg_fs! {
|
||||
|
||||
@@ -20,10 +20,7 @@ pub(crate) struct BlockingSchedule {
|
||||
|
||||
impl BlockingSchedule {
|
||||
#[cfg_attr(not(feature = "test-util"), allow(unused_variables))]
|
||||
pub(crate) fn new(
|
||||
handle: &Handle,
|
||||
#[cfg(tokio_unstable)] run_task_hooks: bool,
|
||||
) -> Self {
|
||||
pub(crate) fn new(handle: &Handle, #[cfg(tokio_unstable)] run_task_hooks: bool) -> Self {
|
||||
#[cfg(feature = "test-util")]
|
||||
{
|
||||
match &handle.inner {
|
||||
|
||||
Reference in New Issue
Block a user