From 5711efbece02743f0902c87ba658e8c880af73e3 Mon Sep 17 00:00:00 2001 From: notplants Date: Tue, 4 Jan 2022 15:00:25 -0500 Subject: [PATCH] Cleanup --- examples/ssb-stream-example.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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]