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

Swoorup · October 3, 2022, 5:19am

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

gist.github.com

https://gist.github.com/Swoorup/41dfcba8d712fb5fa03a38119a1d7088

restartable.rs

use std::task::Poll;

use futures::{Future, FutureExt, Stream};
use pin_project::pin_project;
use tracing::debug;

#[pin_project(project = StreamStateProj)]
#[derive(Debug, Clone)]
enum StreamState<F, S>
where

This file has been truncated. show original

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?

Swoorup · October 3, 2022, 5:27am

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?

RedDocMD · October 3, 2022, 5:37am

@matklad can help perhaps.

matklad · October 3, 2022, 11:06am

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

Swoorup · October 21, 2022, 9:39am

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

system · January 19, 2023, 9:40am

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.