From 72881d86a81165c5c3d3b54a6337bfd02b8bdbc5 Mon Sep 17 00:00:00 2001
From: Jake McGinty <me@jake.su>
Date: Fri, 1 Jun 2018 22:10:29 -0500
Subject: use unbounded_send in thread pool

---
 src/crypto_pool.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/crypto_pool.rs b/src/crypto_pool.rs
index b77b9fd..2208e98 100644
--- a/src/crypto_pool.rs
+++ b/src/crypto_pool.rs
@@ -78,12 +78,12 @@ fn worker(receiver: Receiver<Work>) {
                     raw_packet.truncate(0);
                 }
 
-                executor::spawn(tx.send(DecryptResult {
+                tx.unbounded_send(DecryptResult {
                     endpoint: element.endpoint,
                     orig_packet: element.packet,
                     out_packet: raw_packet,
                     session_type: element.session_type,
-                })).wait_future();
+                }).unwrap();
             },
             Work::Encrypt((tx, mut element)) => {
                 let padding        = if element.in_packet.len() % PADDING_MULTIPLE != 0 {
@@ -102,11 +102,11 @@ fn worker(receiver: Receiver<Work>) {
                     &mut out_packet[16..]).unwrap();
                 out_packet.truncate(TRANSPORT_HEADER_SIZE + len);
 
-                executor::spawn(tx.send(EncryptResult {
+                tx.unbounded_send(EncryptResult {
                     endpoint: element.endpoint,
                     our_index: element.our_index,
                     out_packet,
-                })).wait_future();
+                }).unwrap();
             }
         }
     }
-- 
cgit v1.2.3-59-g8ed1b