Skip to content

Commit

Permalink
Fix: Ringbuf patch release requires explicit type param
Browse files Browse the repository at this point in the history
  • Loading branch information
FelixMcFelix committed Aug 17, 2024
1 parent 2d7dc29 commit 3cb197f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/input/adapters/async_adapter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ use async_trait::async_trait;
use flume::{Receiver, RecvError, Sender, TryRecvError};
use futures::{future::Either, stream::FuturesUnordered, FutureExt, StreamExt};
use parking_lot::Mutex;
use ringbuf::{traits::*, *};
use ringbuf::{storage::Heap, traits::*, *};
use std::{
io::{
Error as IoError,
Expand Down Expand Up @@ -156,7 +156,7 @@ impl AsyncAdapterStream {
/// between the async and sync halves.
#[must_use]
pub fn new(stream: Box<dyn AsyncMediaSource>, buf_len: usize) -> AsyncAdapterStream {
let (bytes_in, bytes_out) = SharedRb::new(buf_len).split();
let (bytes_in, bytes_out) = SharedRb::<Heap<_>>::new(buf_len).split();
let bytes_out = bytes_out.into();
let (resp_tx, resp_rx) = flume::unbounded();
let (req_tx, req_rx) = flume::unbounded();
Expand Down

0 comments on commit 3cb197f

Please sign in to comment.