Skip to content

Commit

Permalink
resolve merge conflict
Browse files Browse the repository at this point in the history
  • Loading branch information
rfdzan committed Apr 20, 2024
1 parent 90b7f73 commit cd03f73
Showing 1 changed file with 1 addition and 27 deletions.
28 changes: 1 addition & 27 deletions src/bulk.rs
Original file line number Diff line number Diff line change
Expand Up @@ -26,12 +26,10 @@ impl ParallelBuilder {
pub fn build(self) -> Parallel {
let (tx, rx) = channel::unbounded();
Parallel {
main_worker: Worker::new_fifo(),
vec: self.vec,
to_thread: StuffThatNeedsToBeSent {
vec: self.vec,
device_num: self.device_num,
quality: self.quality,
stealers: Vec::with_capacity(usize::from(self.device_num)),
},
transmitter: tx,
receiver: rx,
Expand Down Expand Up @@ -64,30 +62,6 @@ impl ParallelBuilder {
}
}
}
impl ParallelBuilder {
/// Builds a new [`Parallel`] with default or specified configuration.
/// # Example
/// This is the minimal requirements for using this method:
/// ```
/// # fn main() {
/// # use jippigy::Parallel;
/// let mut vector_of_bytes: Vec<Vec<u8>> = Vec::new();
/// let _build = Parallel::from_vec(vector_of_bytes).build();
/// # }
/// ```
pub fn build(self) -> Parallel {
let (tx, rx) = channel::unbounded();
Parallel {
to_thread: StuffThatNeedsToBeSent {
vec: self.vec,
device_num: self.device_num,
quality: self.quality,
},
transmitter: tx,
receiver: rx,
}
}
}

#[derive(Debug)]
pub struct StuffThatNeedsToBeSent {
Expand Down

0 comments on commit cd03f73

Please sign in to comment.