a
точнее, наверное, "не должен"
Size: a a a
2020 November 27
MB
Не должно, да
a
понял. спасибо за помощь.
ДБ
подскажите плиз, можно ли как то склонировать стрим из tokio, чтобы потом в 2 местах его читать и получать идентичные даные? у данных Clone есть
ДБ
ну кроме как руками обертку писать?
MB
Во futures-util я такого комбинатора (аналогичного shared() для футур) не вижу
С
Во futures-util я такого комбинатора (аналогичного shared() для футур) не вижу
если превратить в futures::Stream, можно обернуть в Either и использовать https://docs.rs/futures/0.3.8/futures/stream/trait.StreamExt.html#method.left_stream
MB
если превратить в futures::Stream, можно обернуть в Either и использовать https://docs.rs/futures/0.3.8/futures/stream/trait.StreamExt.html#method.left_stream
1) это и есть futures::Stream, токио его просто реэкспортит
2) И как это поможет?
2) И как это поможет?
ДБ
а может можно как то по другому решить, у меня кейс примерно такой:
есть стрим с событиями, ну и есть некая реакция на эти события, я хочу посередине запись в лог добавить
есть стрим с событиями, ну и есть некая реакция на эти события, я хочу посередине запись в лог добавить
MB
вообще, можно заиспользовать tokio::sync::broadcast
MB
В этом канале каждое посланное сообщение будет прочитано каждым из ресиверов
С
1) это и есть futures::Stream, токио его просто реэкспортит
2) И как это поможет?
2) И как это поможет?
В кейсе, который ты описал уже потом - никак )
Если ты хочешь инжект в стрим, можно в then/map возвращать стрим из нескольких элементов и делать flat_map
Если ты хочешь инжект в стрим, можно в then/map возвращать стрим из нескольких элементов и делать flat_map
MB
Я никаких кейсов не описывал.
Вот что хотел ОП:
> склонировать стрим из tokio, чтобы потом в 2 местах его читать и получать идентичные даные
Вот что хотел ОП:
> склонировать стрим из tokio, чтобы потом в 2 местах его читать и получать идентичные даные
С
Я никаких кейсов не описывал.
Вот что хотел ОП:
> склонировать стрим из tokio, чтобы потом в 2 местах его читать и получать идентичные даные
Вот что хотел ОП:
> склонировать стрим из tokio, чтобы потом в 2 местах его читать и получать идентичные даные
да, сорян, не ты. но ОП потом написал
у меня кейс примерно такой:
есть стрим с событиями, ну и есть некая реакция на эти события, я хочу посередине запись в лог добавить
у меня кейс примерно такой:
есть стрим с событиями, ну и есть некая реакция на эти события, я хочу посередине запись в лог добавить
ДБ
вообще, можно заиспользовать tokio::sync::broadcast
спасибо, это подходит
как понял спокойно смогу существующему коду аналогичный стрим отдать через это https://docs.rs/tokio/0.3.4/tokio/sync/broadcast/struct.Receiver.html#method.into_stream
как понял спокойно смогу существующему коду аналогичный стрим отдать через это https://docs.rs/tokio/0.3.4/tokio/sync/broadcast/struct.Receiver.html#method.into_stream
a
можно заставить serde пробрасывать таг внутрь значений энумов?
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=01a63af558752a010c5f5a6fdb741d01
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=01a63af558752a010c5f5a6fdb741d01
С
можно заставить serde пробрасывать таг внутрь значений энумов?
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=01a63af558752a010c5f5a6fdb741d01
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=01a63af558752a010c5f5a6fdb741d01
свой Deserialize для перечисления реализовать, точно сработает
но я думаю ты это и сам знаешь 🙂
но я думаю ты это и сам знаешь 🙂
a
свой Deserialize для перечисления реализовать, точно сработает
но я думаю ты это и сам знаешь 🙂
но я думаю ты это и сам знаешь 🙂
слишком банально. привет :)
/
не знаю насколько вопрос про раст, но возникла проблема с rocket
/
от юзера он запускается только через sudo из-за 80 порта