Skip to content

Commit

Permalink
Fix clippy issue
Browse files Browse the repository at this point in the history
  • Loading branch information
mankinskin committed Dec 11, 2020
1 parent ebd8ab3 commit 46cada6
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions src/websocket_connection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@ use std::pin::Pin;
use async_dup::{Arc, Mutex};
use async_std::task;
use async_tungstenite::WebSocketStream;
use futures_util::sink::Sink;
use futures_util::stream::{SplitSink, SplitStream, Stream};
use futures_util::sink::{Sink};
use futures_util::{SinkExt, StreamExt};

use crate::Message;
Expand Down Expand Up @@ -64,10 +64,7 @@ impl Sink<Message> for WebSocketConnection {
) -> task::Poll<Result<(), Self::Error>> {
Sink::poll_ready(Pin::new(&mut *self.0.lock()), cx)
}
fn start_send(
self: Pin<&mut Self>,
item: Message,
) -> Result<(), Self::Error> {
fn start_send(self: Pin<&mut Self>, item: Message) -> Result<(), Self::Error> {
Sink::start_send(Pin::new(&mut *self.0.lock()), item)
}
fn poll_flush(
Expand Down

0 comments on commit 46cada6

Please sign in to comment.