File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed
Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -32,7 +32,6 @@ timely_bytes = { path = "../bytes", version = "0.13" }
3232timely_logging = { path = " ../logging" , version = " 0.13" }
3333timely_communication = { path = " ../communication" , version = " 0.19" , default-features = false }
3434timely_container = { path = " ../container" , version = " 0.15" }
35- crossbeam-channel = " 0.5"
3635smallvec = { version = " 1.13.2" , features = [" serde" , " const_generics" ] }
3736
3837[dev-dependencies ]
Original file line number Diff line number Diff line change @@ -6,7 +6,7 @@ use std::thread::Thread;
66use std:: collections:: BinaryHeap ;
77use std:: time:: { Duration , Instant } ;
88use std:: cmp:: Reverse ;
9- use crossbeam_channel :: { Sender , Receiver } ;
9+ use std :: sync :: mpsc :: { Sender , Receiver } ;
1010
1111/// Methods required to act as a timely scheduler.
1212///
@@ -56,7 +56,7 @@ impl Activations {
5656
5757 /// Creates a new activation tracker.
5858 pub fn new ( timer : Option < Instant > ) -> Self {
59- let ( tx, rx) = crossbeam_channel :: unbounded ( ) ;
59+ let ( tx, rx) = std :: sync :: mpsc :: channel ( ) ;
6060 Self {
6161 clean : 0 ,
6262 bounds : Vec :: new ( ) ,
You can’t perform that action at this time.
0 commit comments