Skip to content

Commit

Permalink
Fix build errors
Browse files Browse the repository at this point in the history
  • Loading branch information
DamienDeepgram committed Jul 25, 2024
1 parent b35152c commit ab8aa32
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions src/listen/websocket.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@ use tokio::net::TcpStream;
use tokio::sync::mpsc::Sender;
use tokio::sync::Mutex;
use tokio::time;
use tokio_tungstenite::{MaybeTlsStream, WebSocketStream};
use tokio_tungstenite::tungstenite::protocol::Message;
use tokio_tungstenite::{MaybeTlsStream, WebSocketStream};
use tokio_util::io::ReaderStream;
use tungstenite::handshake::client;
use url::Url;
Expand Down Expand Up @@ -274,8 +274,8 @@ impl TranscriptionStream {
eprintln!("Error sending Finalize message: {:?}", err);
event_tx.send(Event::Error(err)).await.unwrap();
return Err(DeepgramError::CustomError(
"Failed to send Finalize message".to_string()),
);
"Failed to send Finalize message".to_string(),
));
}
Ok(())
}
Expand Down Expand Up @@ -305,7 +305,10 @@ where
mut self,
event_tx: Sender<Event>,
) -> std::result::Result<
(TranscriptionStream, futures_mpsc::Receiver<std::result::Result<StreamResponse, DeepgramError>>),
(
TranscriptionStream,
futures_mpsc::Receiver<std::result::Result<StreamResponse, DeepgramError>>,
),
DeepgramError,
> {
// This unwrap is safe because we're parsing a static.
Expand Down

0 comments on commit ab8aa32

Please sign in to comment.