diff options
Diffstat (limited to 'crates/thread_worker/src')
-rw-r--r-- | crates/thread_worker/src/lib.rs | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/crates/thread_worker/src/lib.rs b/crates/thread_worker/src/lib.rs index 5e46f62fe..ca0aad136 100644 --- a/crates/thread_worker/src/lib.rs +++ b/crates/thread_worker/src/lib.rs | |||
@@ -71,12 +71,5 @@ impl WorkerHandle { | |||
71 | fn worker_chan<I, O>(buf: usize) -> (Worker<I, O>, Receiver<I>, Sender<O>) { | 71 | fn worker_chan<I, O>(buf: usize) -> (Worker<I, O>, Receiver<I>, Sender<O>) { |
72 | let (input_sender, input_receiver) = bounded::<I>(buf); | 72 | let (input_sender, input_receiver) = bounded::<I>(buf); |
73 | let (output_sender, output_receiver) = unbounded::<O>(); | 73 | let (output_sender, output_receiver) = unbounded::<O>(); |
74 | ( | 74 | (Worker { inp: input_sender, out: output_receiver }, input_receiver, output_sender) |
75 | Worker { | ||
76 | inp: input_sender, | ||
77 | out: output_receiver, | ||
78 | }, | ||
79 | input_receiver, | ||
80 | output_sender, | ||
81 | ) | ||
82 | } | 75 | } |