D
Size: a a a
2020 October 27
D
можно в принципе через баундед-стримы запилить, типа заспавнить таску, которая бы всё время принимала новые соединения и перекладывала бы их в баундед канал, и сделать *стрим*, который бы брал оттуда соединения и заворачивал их TlsStream, и вот этот *стрим* уже отдать хайперу
D
получится такая backpressure штука, вроде даже должно работать нормально
D
но кажется, что надёжнее всё-таки сделать ленивый враппер :)
ID
а ну это объясняет почему в warp столько boilerplate: https://github.com/seanmonstar/warp/blob/master/src/tls.rs
ID
они как раз ленивый TlsStream делают
D
лол
D
странно, что это в самом tokio-rustls не делается
D
можно наверное законтрибутить им LazyTlsStream :)
RG
Как такое может быть?
tokio::join!(fn1(), fn2()) вечно висит. fn1().await; fn2().await почти мгновенно отрабатывают. Синхронизации у функций нет, чисто по http сходить и забрать json. С разных адресов.A
А вы авейт у джоина вызвали?)
A
🤪
в🧇
Adv0cat
А вы авейт у джоина вызвали?)
токиевский
join! сам авейтитA
пошутить уже нельзя 😃
RG
Как такое может быть?
tokio::join!(fn1(), fn2()) вечно висит. fn1().await; fn2().await почти мгновенно отрабатывают. Синхронизации у функций нет, чисто по http сходить и забрать json. С разных адресов.Короче что-то странное было. Переписал функции и заработало
АГ
Короче что-то странное было. Переписал функции и заработало
можете скинуть MRE? интересно все же, вдруг в токио бага какая
2020 October 28
a
доброго вечера
не уверен, что в писанине будут разбираться в этом канале. и не уверен, что вопрос вообще в этот канал.
короче: хочу реализовать курсор на futures::Stream. и чет я не осилил.
вот тут пример: https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=e65c3ff835e52d69db0ba40c350bbe01
если кто-то хоть чуть проникнется или мб у кого-то есть что-то похожее - буду благодарен за помощь
не уверен, что в писанине будут разбираться в этом канале. и не уверен, что вопрос вообще в этот канал.
короче: хочу реализовать курсор на futures::Stream. и чет я не осилил.
вот тут пример: https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=e65c3ff835e52d69db0ba40c350bbe01
если кто-то хоть чуть проникнется или мб у кого-то есть что-то похожее - буду благодарен за помощь
IT
доброго вечера
не уверен, что в писанине будут разбираться в этом канале. и не уверен, что вопрос вообще в этот канал.
короче: хочу реализовать курсор на futures::Stream. и чет я не осилил.
вот тут пример: https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=e65c3ff835e52d69db0ba40c350bbe01
если кто-то хоть чуть проникнется или мб у кого-то есть что-то похожее - буду благодарен за помощь
не уверен, что в писанине будут разбираться в этом канале. и не уверен, что вопрос вообще в этот канал.
короче: хочу реализовать курсор на futures::Stream. и чет я не осилил.
вот тут пример: https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=e65c3ff835e52d69db0ba40c350bbe01
если кто-то хоть чуть проникнется или мб у кого-то есть что-то похожее - буду благодарен за помощь
Вообще это можно сделать на комбинаторах, например на https://docs.rs/futures/0.3.7/futures/stream/fn.unfold.html
https://github.com/Leonqn/rutebot/blob/master/src/client.rs#L187 вот тут я делал что-то похожее
https://github.com/Leonqn/rutebot/blob/master/src/client.rs#L187 вот тут я делал что-то похожее
a
спасибо, попробую переварить
a
лол, как раз для телеги и делаю. ток не поверх бот апи, а поверх tdlib