f
А из чего в multipart? 🤔
Size: a a a
2020 August 02
В
А из чего в multipart? 🤔
>
serde
Т.е. любая плоская структура с #[derive(Serialize)] + костыльчик чтобы сериализовывать файлыf
>
serde
Т.е. любая плоская структура с #[derive(Serialize)] + костыльчик чтобы сериализовывать файлыА оно бьётся по частям прям при достижении какого-то размера? Тогда весьма полезно
В
А оно бьётся по частям прям при достижении какого-то размера? Тогда весьма полезно
ахз, я просто вызываю
form.part(key, part) и танцую с бубнами над фьючами и файлами. По идее reqwest должен уметь бить сам (особенно учитывая что он поддерживает оборачивание стримов)В
Initial commit живёт здесь: https://github.com/WaffleLapkin/serde-multipart
(дока не билдиться из-за бага в растдоке, ugh)
(дока не билдиться из-за бага в растдоке, ugh)
2020 August 03
H
Есть ли способ в
tokio::sync::mpsc::UnboundedSender пайплайнить мой другой стрим?С
Есть ли способ в
tokio::sync::mpsc::UnboundedSender пайплайнить мой другой стрим?Почему нет, он же Sink
https://docs.rs/futures/0.3.5/futures/stream/trait.StreamExt.html#method.forward
https://docs.rs/futures/0.3.5/futures/stream/trait.StreamExt.html#method.forward
H
Ага, точно
H
Почему нет, он же Sink
https://docs.rs/futures/0.3.5/futures/stream/trait.StreamExt.html#method.forward
https://docs.rs/futures/0.3.5/futures/stream/trait.StreamExt.html#method.forward
Не, а в Tokio как? При том я хочу
SendError<T>, а не просто SendErrorH
В futures только
SendError без сообщенияH
А в Tokio
SendError<T>, но реализацию Sink я там не вижуС
Не, а в Tokio как? При том я хочу
SendError<T>, а не просто SendErrorВ токио свои stream и sink, в них я не нашёл forward, ты можешь сделать через compat, которые делают токио стрим и синк футуро-совместимыми
С
ну или
while let Some(msg) = stream.recv().await {}...H
Понял
DZ
Народ глупый вопрос , есть потребность передавать разные структуры в один mpsc канал
V
let c: Vec<Box<(dyn Message + 'static)>> = vec![Box::new(foo)];
V
поправь и все заработает, чуток помоги компилятору)
V
там коэрции не происходит просто иначе
D
достаточно сделать
let c = vec![Box::new(foo) as _];