summaryrefslogtreecommitdiffstats
path: root/tokio-sync
diff options
context:
space:
mode:
authorCarl Lerche <me@carllerche.com>2019-06-27 00:05:01 -0700
committerGitHub <noreply@github.com>2019-06-27 00:05:01 -0700
commited4d4a5353d07d2428072965ea23c9a6eba5d87d (patch)
treee18da92f826a22eb253cc5d41149457a547910a3 /tokio-sync
parent1f47ed3dcc4b582315cdbfb195495d7d4c76d3f3 (diff)
chore: format code and enable rustfmt CI task (#1212)
Diffstat (limited to 'tokio-sync')
-rw-r--r--tokio-sync/src/mpsc/bounded.rs10
1 files changed, 4 insertions, 6 deletions
diff --git a/tokio-sync/src/mpsc/bounded.rs b/tokio-sync/src/mpsc/bounded.rs
index 7f8cb905..67134156 100644
--- a/tokio-sync/src/mpsc/bounded.rs
+++ b/tokio-sync/src/mpsc/bounded.rs
@@ -200,12 +200,10 @@ impl<T> async_sink::Sink<T> for Sender<T> {
}
fn start_send(mut self: Pin<&mut Self>, msg: T) -> Result<(), Self::Error> {
- self.as_mut()
- .try_send(msg)
- .map_err(|err| {
- assert!(err.is_full(), "call `poll_ready` before sending");
- SendError(())
- })
+ self.as_mut().try_send(msg).map_err(|err| {
+ assert!(err.is_full(), "call `poll_ready` before sending");
+ SendError(())
+ })
}
fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {