PubsubClient: Unable to use .next() after logs_subscribe subscription initialized

[bologer]

Problem

I'm using PubsubClient to subscribe to new logs using logs_subscribe.
However, when I run this code, it ends up wit the following error:

error[E0599]: no method named `next` found for struct `Pin<Box<dyn futures_core::stream::Stream<Item = solana_client::rpc_response::Response<RpcLogsResponse>> + Send>>` in the current scope
  --> src/main.rs:90:27
   |
90 |         let logs = stream.next().await.unwrap();
   |                           ^^^^ method not found in `Pin<Box<dyn Stream<Item = Response<RpcLogsResponse>> + Send>>`
   |
   = help: items from traits can only be used if the trait is in scope
help: the following traits are implemented but not in scope; perhaps add a `use` for one of them:
   |
1  + use enum_iterator::Sequence;
   |
1  + use futures_util::stream::stream::StreamExt;
   |
1  + use serde_json::de::Read;
   |
1  + use std::iter::Iterator;
   |
     and 2 other candidates

Here is minimal code:

// ...
use solana_client::nonblocking::pubsub_client::PubsubClient;
use solana_client::rpc_config::{RpcAccountInfoConfig, RpcProgramAccountsConfig, RpcTransactionLogsConfig, RpcTransactionLogsFilter};

#[tokio::main]
async fn main() {
    let ws_client: PubsubClient = PubsubClient::new(&config.rpc_ws).await.unwrap();

    let (mut stream, _) = ws_client
        .logs_subscribe(
            RpcTransactionLogsFilter::All,
            RpcTransactionLogsConfig {
                commitment: Some(CommitmentConfig::processed()),
            },
        )
        .await?;

    loop {
        let logs = stream.next().await.unwrap();
        println!("logs: {:?}", logs);
    }
}

The issue is happening also when using any other subscription methods, such as program_subscribe.

More debug info:

$ rustc --version
rustc 1.77.2 (25ef9e3d8 2024-04-09)

Cargo.toml:

[dependencies]
solana-client = "1.18.11"

Any idea why this could be happening?

Proposed Solution

[github-actions]

This repository is no longer in use. Please re-open this issue in the agave repo: https://github.com/anza-xyz/agave