A
Size: a a a
A
D
use trait
?A
D
use and_then2::FutureExt
или типа тогоD
firstCodecFramed.for_each(|data, addr| {Где я неправильно думаю? ։)
let secondCodecFramed = UdpFramed::new(firstCodecFramed.get_ref(), secondCodec);
///
}
let (packet_sender, packet_sender_receiver) = futures::sync::mpsc::channel(10);То есть у меня есть mpsc channel для отправки данных в сокет в дальнейшем все данные сливаются в него, но хочется так же уметь отправить пакет и отреагировать на его получение с помощью
let (sink, stream) = self.framed.split();
Box::new(
stream
.for_each(move |(data, addr)| {
Cacher::process_request(packet_sender.clone(), &data.freeze(), addr)
})
.map_err(|e| {
error!("Stream error inside for_each {}", e);
})
.join(packet_sender_receiver.forward(sink.sink_map_err(|e| {
error!("Sink error inside receiver {}", e);
})))
.map(|_| {}),
)
and_then
.socket.send(someData)
.and_then(socket.receiveData())
A
D
A
A
D
A
self
. Вообщем-с гораздо важнее второй вопрос, потому что первый это моё недопониманиеA
A
Box<Future>
?D
D
D
D
D
A
V