B
Size: a a a
B
АИ
П
TK
LM
Кодяра -
pub(super) fn prepare_and_start_receiving_data(mut self) {
let DataReceiver {
mut sender,
mut runtime,
mut socket,
} = self;
std::thread::spawn(move || {
runtime.block_on(Self::receive_data(sender, socket));
});
}
async fn receive_data(sender: mpsc::Sender<Bytes>, mut socket: SrtSocket) {
let mut socket_with_timeout = socket.timeout(Duration::from_millis(20));
tokio::pin!(socket_with_timeout);
loop {
match socket_with_timeout.try_next().await {*handling cases* }
}
D
impl Read?П
DF
DF
С
TK
Э
PI
МТ
DF
МТ
TK