tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-09-06 00:00:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

sync: remove rt-core from blocking_{send,recv} (#2825)

Browse Source
This commit is contained in:
Blas Rodriguez Irizar
2020-09-08 20:50:38 -07:00
committed by GitHub
parent ea79c95c67
commit a0a356152e
1 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/src/sync/mpsc/bounded.rs
-4
View File
@@ -184,8 +184,6 @@ impl<T> Receiver<T> {
/// sync_code.join().unwrap() /// sync_code.join().unwrap()
/// } /// }
/// ``` /// ```
#[cfg(feature = "rt-core")]
#[cfg_attr(docsrs, doc(cfg(feature = "rt-core")))]
pub fn blocking_recv(&mut self) -> Option<T> { pub fn blocking_recv(&mut self) -> Option<T> {
let mut enter_handle = crate::runtime::enter::enter(false); let mut enter_handle = crate::runtime::enter::enter(false);
enter_handle.block_on(self.recv()).unwrap() enter_handle.block_on(self.recv()).unwrap()
@@ -456,8 +454,6 @@ impl<T> Sender<T> {
/// sync_code.join().unwrap() /// sync_code.join().unwrap()
/// } /// }
/// ``` /// ```
#[cfg(feature = "rt-core")]
#[cfg_attr(docsrs, doc(cfg(feature = "rt-core")))]
pub fn blocking_send(&mut self, value: T) -> Result<(), SendError<T>> { pub fn blocking_send(&mut self, value: T) -> Result<(), SendError<T>> {
let mut enter_handle = crate::runtime::enter::enter(false); let mut enter_handle = crate::runtime::enter::enter(false);
enter_handle.block_on(self.send(value)).unwrap() enter_handle.block_on(self.send(value)).unwrap()