Remove crossbeam-channel in favor of crossbeam

Author: martskins

Cargo.lock

@@ -25,9 +25,7 @@ maplit = "1"
 serde = "1"
 serde_derive = "1"
 serde_json = "1"
-
-crossbeam-channel = "0.3"
-
+crossbeam = "0.7.3"
 jsonrpc-core = "12"
 lsp-types = "0.60"
 url = "2"

Cargo.toml

@@ -23,7 +23,7 @@ impl LanguageClient {
             })
     }
 
-    pub fn loop_call(&self, rx: &crossbeam_channel::Receiver<Call>) -> Fallible<()> {
+    pub fn loop_call(&self, rx: &crossbeam::channel::Receiver<Call>) -> Fallible<()> {
         for call in rx.iter() {
             let language_client = LanguageClient {
                 state_mutex: self.state_mutex.clone(),

src/language_server_protocol.rs

@@ -60,7 +60,7 @@ fn main() -> Fallible<()> {
     let args = Arguments::clap().version(version.as_str());
     let _ = args.get_matches();
 
-    let (tx, rx) = crossbeam_channel::unbounded();
+    let (tx, rx) = crossbeam::channel::unbounded();
     let language_client = language_client::LanguageClient {
         state_mutex: Arc::new(Mutex::new(State::new(tx)?)),
         clients_mutex: Arc::new(Mutex::new(HashMap::new())),

src/main.rs

@@ -1,6 +1,6 @@
 use super::*;
 use crate::types::{Call, RawMessage};
-use crossbeam_channel::{bounded, unbounded, Receiver, Sender};
+use crossbeam::channel::{bounded, unbounded, Receiver, Sender};
 
 #[derive(Clone, Serialize)]
 pub struct RpcClient {

src/rpcclient.rs

@@ -99,7 +99,7 @@ pub struct HighlightSource {
 pub struct State {
     // Program state.
     #[serde(skip_serializing)]
-    pub tx: crossbeam_channel::Sender<Call>,
+    pub tx: crossbeam::channel::Sender<Call>,
 
     #[serde(skip_serializing)]
     pub clients: HashMap<LanguageId, RpcClient>,
@@ -170,7 +170,7 @@ pub struct State {
 
 impl State {
     #[allow(clippy::new_ret_no_self)]
-    pub fn new(tx: crossbeam_channel::Sender<Call>) -> Fallible<Self> {
+    pub fn new(tx: crossbeam::channel::Sender<Call>) -> Fallible<Self> {
         let logger = logger::init()?;
 
         let client = RpcClient::new(