|
@@ -251,7 +251,7 @@ impl LatencyManager<WTen> { |
|
|
if let Ok(msg) = rx.recv() { |
|
|
if let Ok(msg) = rx.recv() { |
|
|
match msg { |
|
|
match msg { |
|
|
ExperiencedLatency::Terminate => { |
|
|
ExperiencedLatency::Terminate => { |
|
|
println!("latency manager terminating"); |
|
|
|
|
|
|
|
|
//println!("latency manager terminating"); |
|
|
break; |
|
|
break; |
|
|
} |
|
|
} |
|
|
ExperiencedLatency::GdaxWebsocket(d) => gdax_ws.update(Instant::now(), d), |
|
|
ExperiencedLatency::GdaxWebsocket(d) => gdax_ws.update(Instant::now(), d), |
|
|