mirror of
https://github.com/tlsnotary/rust-yamux.git
synced 2026-01-08 04:23:51 -05:00
chore: fix minor warnings (#181)
This commit is contained in:
1
.github/workflows/rust.yml
vendored
1
.github/workflows/rust.yml
vendored
@@ -8,6 +8,7 @@ on:
|
|||||||
|
|
||||||
env:
|
env:
|
||||||
CARGO_TERM_COLOR: always
|
CARGO_TERM_COLOR: always
|
||||||
|
RUSTFLAGS: '-Dwarnings' # Never tolerate warnings.
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
build:
|
build:
|
||||||
|
|||||||
@@ -451,6 +451,7 @@ impl Arbitrary for TestConfig {
|
|||||||
c.set_window_update_mode(if bool::arbitrary(g) {
|
c.set_window_update_mode(if bool::arbitrary(g) {
|
||||||
WindowUpdateMode::OnRead
|
WindowUpdateMode::OnRead
|
||||||
} else {
|
} else {
|
||||||
|
#[allow(deprecated)]
|
||||||
WindowUpdateMode::OnReceive
|
WindowUpdateMode::OnReceive
|
||||||
});
|
});
|
||||||
c.set_read_after_close(Arbitrary::arbitrary(g));
|
c.set_read_after_close(Arbitrary::arbitrary(g));
|
||||||
|
|||||||
@@ -33,7 +33,7 @@ impl Future for Cleanup {
|
|||||||
type Output = ConnectionError;
|
type Output = ConnectionError;
|
||||||
|
|
||||||
fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
|
fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
|
||||||
let mut this = self.get_mut();
|
let this = self.get_mut();
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
match this.state {
|
match this.state {
|
||||||
|
|||||||
@@ -45,7 +45,7 @@ where
|
|||||||
type Output = Result<()>;
|
type Output = Result<()>;
|
||||||
|
|
||||||
fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
|
fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
|
||||||
let mut this = self.get_mut();
|
let this = self.get_mut();
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
match this.state {
|
match this.state {
|
||||||
|
|||||||
@@ -171,7 +171,7 @@ impl<T: AsyncRead + AsyncWrite + Unpin> Stream for Io<T> {
|
|||||||
type Item = Result<Frame<()>, FrameDecodeError>;
|
type Item = Result<Frame<()>, FrameDecodeError>;
|
||||||
|
|
||||||
fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
|
fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
|
||||||
let mut this = &mut *self;
|
let this = &mut *self;
|
||||||
loop {
|
loop {
|
||||||
log::trace!("{}: read: {:?}", this.id, this.read_state);
|
log::trace!("{}: read: {:?}", this.id, this.read_state);
|
||||||
match this.read_state {
|
match this.read_state {
|
||||||
|
|||||||
Reference in New Issue
Block a user