From c2c10b9014549e9c0783fb13dc202dfab6e6fd0a Mon Sep 17 00:00:00 2001
From: Aleksey Kladov <aleksey.kladov@gmail.com>
Date: Sun, 30 Dec 2018 23:23:31 +0300
Subject: :arrow_up: crossbeam

closes #189
---
 crates/thread_worker/src/lib.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'crates/thread_worker/src')

diff --git a/crates/thread_worker/src/lib.rs b/crates/thread_worker/src/lib.rs
index 12e8bf17e..5e46f62fe 100644
--- a/crates/thread_worker/src/lib.rs
+++ b/crates/thread_worker/src/lib.rs
@@ -2,7 +2,7 @@
 
 use std::thread;
 
-use crossbeam_channel::{bounded, unbounded, Receiver, Sender};
+use crossbeam_channel::{bounded, unbounded, Receiver, Sender, RecvError, SendError};
 use drop_bomb::DropBomb;
 
 pub struct Worker<I, O> {
@@ -34,10 +34,10 @@ impl<I, O> Worker<I, O> {
         self.out
     }
 
-    pub fn send(&self, item: I) {
+    pub fn send(&self, item: I) -> Result<(), SendError<I>> {
         self.inp.send(item)
     }
-    pub fn recv(&self) -> Option<O> {
+    pub fn recv(&self) -> Result<O, RecvError> {
         self.out.recv()
     }
 }
-- 
cgit v1.2.3