python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - rust-futures

Call stored closure from an async closure in rust

I have a closure that mutates variables designed outside of it. How would I go about calling this closure that modifies the state from inside an async scope? I have the following code (abstracted, to ...
test-img

SnailsSeveral

rust

rust-tokio

rust-futures

Votes: 0

Answers: 1

Latest Answer

In rust, usually, you need to use some kind of synchronization mechanisms. It would be really difficult to send a reference to a normal variable. So you would need to use some Arc, RwLock, Mutex depen...
test-img

Netwave

Chaining adapters with custom `futures::Stream` breaks trait bounds

I needed to implement a custom Stream that yields items in a sliding window (ie. [1, 2, 3] => [(1, 2), (2, 3)]). So I implemented and gave it an adapter called .tuple_windows(). Allowing the follow...
test-img

Midnight Exigent

rust

rust-futures

Votes: 0

Answers: 2

Latest Answer

Your Stream implementation requires that items from the inner stream be cloneable: impl<S: Stream> Stream for TupleWindows<S> where S::Item: Clone, In the working case, stream::iter(0...
test-img

Francis Gagn&#233;

Is there a tuple_windows() adapter for async streams?

I have a code the looks like this use itertools::Itertools; let (tx, rx) = std::sync::mpsc::channel(); tokio::spawn(async move { for (v1, v2) in rx.into_iter().tuple_windows() { // do so...
test-img

Midnight Exigent

rust

rust-futures

Votes: 0

Answers: 2

Latest Answer

There is a StreamExt from Futures. There is no windows functionality there, but you could use it to implement your own extension over it. Something like: use async_trait::async_trait; use futures::str...
test-img

Netwave

Posts

Questions

Blogs

Jobs