Remove todo
This commit is contained in:
parent
f5ba899a36
commit
1c0f73b6b0
1 changed files with 0 additions and 2 deletions
|
|
@ -533,8 +533,6 @@ impl ConnRx {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO Combine ConnTx and ConnRx and implement Stream + Sink?
|
|
||||||
|
|
||||||
pub fn wrap(ws: WsStream, timeout: Duration) -> (ConnTx, ConnRx) {
|
pub fn wrap(ws: WsStream, timeout: Duration) -> (ConnTx, ConnRx) {
|
||||||
let (tx_canary_tx, tx_canary_rx) = mpsc::unbounded_channel();
|
let (tx_canary_tx, tx_canary_rx) = mpsc::unbounded_channel();
|
||||||
let (rx_canary_tx, rx_canary_rx) = oneshot::channel();
|
let (rx_canary_tx, rx_canary_rx) = oneshot::channel();
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue