golgi-ssb
/
golgi
4
5
Fork 0
Code Issues 11 Pull Requests 1 Projects 1 Releases Wiki Activity

Cleanup

This commit is contained in:
notplants 2022-01-04 15:00:25 -05:00
parent 5927b7dfe6
commit 5711efbece
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
examples/ssb-stream-example.rs
View File

@ -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]