diff --git a/examples/ssb-stream-example.rs b/examples/ssb-stream-example.rs index ee91685..3f056e7 100644 --- a/examples/ssb-stream-example.rs +++ b/examples/ssb-stream-example.rs @@ -3,9 +3,9 @@ use std::process; use golgi::error::GolgiError; use golgi::sbot::Sbot; -use async_std::stream::{Stream, StreamExt}; -use futures::{pin_mut, TryStreamExt}; -use golgi::messages::{SsbMessageContentType, SsbMessageValue}; +use async_std::stream::{StreamExt}; +use futures::{pin_mut}; + async fn run() -> Result<(), GolgiError> { @@ -17,7 +17,7 @@ async fn run() -> Result<(), GolgiError> { let author = "@L/z54cbc8V1kL1/MiBhpEKuN3QJkSoZYNaukny3ghIs=.ed25519"; // create a history stream - let mut history_stream = sbot_client.create_history_stream(author.to_string()).await?; + let history_stream = sbot_client.create_history_stream(author.to_string()).await?; // loop through the results until the end of the stream pin_mut!(history_stream); // needed for iteration @@ -80,7 +80,7 @@ async fn run() -> Result<(), GolgiError> { // println!("reached end of type stream"); // // // return Ok - // Ok(()) + Ok(()) } #[async_std::main]