We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e5c22d9 commit 2e10895Copy full SHA for 2e10895
src/transport.rs
@@ -171,6 +171,8 @@ impl TcpMessageBus {
171
})
172
}
173
174
+ // Dispatcher thread reads messages from TWS and dispatches them to
175
+ // appropriate channel.
176
fn start_dispatcher_thread(&mut self, server_version: i32) -> JoinHandle<i32> {
177
let reader = Arc::clone(&self.reader);
178
let requests = Arc::clone(&self.requests);
@@ -193,6 +195,8 @@ impl TcpMessageBus {
193
195
194
196
197
198
+ // The cleanup thread receives signals as subscribers are dropped and
199
+ // releases the sender channels
200
fn start_cleanup_thread(&mut self) -> JoinHandle<i32> {
201
202
let orders = Arc::clone(&self.orders);
0 commit comments