How to get future-rs StreamExt extensions on custom stream combinator?

So I wrote a stream combinator to auto restart a stream if completed.

My question is how can I get autocompletion for other combinators such as map, take_until like the ones in futures-rs library?

I only get at the moment.

I want to get other combinators like the default ones here without doing a pin_mut

Am I missing some trait implementation?

So it seems that this is an IDE issue (both IntelliJ Rust, VSCode), I have import StreamExt I can write like

    let stream = Restartable::of(connect, self.param.clone()).take(3);

It seems to compile just fine, but I don't get any help from the IDE. Any ideas?

@matklad can help perhaps.

Minimal reproducible example would help! At least this works for me:

You are right, I am not sure what it was but removing the target directory and rebuild fixed my problem.

This topic was automatically closed 90 days after the last reply. We invite you to open a new topic if you have further questions or comments.