diff options
author | Carl Lerche <me@carllerche.com> | 2019-06-27 00:05:01 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-06-27 00:05:01 -0700 |
commit | ed4d4a5353d07d2428072965ea23c9a6eba5d87d (patch) | |
tree | e18da92f826a22eb253cc5d41149457a547910a3 /tokio-sync | |
parent | 1f47ed3dcc4b582315cdbfb195495d7d4c76d3f3 (diff) |
chore: format code and enable rustfmt CI task (#1212)
Diffstat (limited to 'tokio-sync')
-rw-r--r-- | tokio-sync/src/mpsc/bounded.rs | 10 |
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>> { |