Skip to content

Commit

Permalink
Fix CI errors
Browse files Browse the repository at this point in the history
Signed-off-by: John Nunley <dev@notgull.net>
  • Loading branch information
notgull committed Dec 30, 2023
1 parent a3f1c84 commit 8575c97
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 132 deletions.
8 changes: 6 additions & 2 deletions axum/src/extract/ws.rs
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,9 @@ impl<F> WebSocketUpgrade<F> {
/// If set to `0` each message will be eagerly written to the underlying stream.
/// It is often more optimal to allow them to buffer a little, hence the default value.
///
/// Note: [`flush`](SinkExt::flush) will always fully write the buffer regardless.
/// Note: [`flush`] will always fully write the buffer regardless.
///
/// [`flush`]: https://docs.rs/futures-util/latest/futures_util/sink/trait.SinkExt.html#method.flush
pub fn write_buffer_size(mut self, size: usize) -> Self {
self.config.write_buffer_size = size;
self
Expand Down Expand Up @@ -475,7 +477,9 @@ impl WebSocket {
poll_fn(|cx| Pin::new(&mut self.inner).poll_ready(cx))
.await
.map_err(Error::new)?;
Pin::new(&mut self.inner).start_send(msg.into_tungstenite()).map_err(Error::new)?;
Pin::new(&mut self.inner)
.start_send(msg.into_tungstenite())
.map_err(Error::new)?;

// Send the message.
poll_fn(|cx| Pin::new(&mut self.inner).poll_flush(cx))
Expand Down
65 changes: 0 additions & 65 deletions rustc-ice-2023-12-30T16_17_52-3660.txt

This file was deleted.

Loading

0 comments on commit 8575c97

Please sign in to comment.