I want to implement the Sink trait for something that is AsyncWrite in order to send n-separated strings.
Essentially I would like to implement the Sink version of tokio-stream LinesStream wrapper.

I have this code

I have this code

I have this code

I have this code

I have a read window struct like this: (runnable example here)

Is the following a good explanation of Async/Await… Async/Await requires a runner or executor with a stack of pending Async state machines that it then pops and the state transition functions of. An Async is a state machine instances (a value). That is, it is a set of possible states, a current state, and a […]

Have a look at this code:

#[tokio::main] async fn main() -> Result<(), Box<dyn Error>> { let bot = Bot::new(TG_TOKEN); let mut users = load_users()?; teloxide::repl(bot, |bot: Bot, msg: Message| async move{ let text = msg.text().unwrap(); match text { “/start” => { bot.send_message(msg.chat.id, TEXT1).await.unwrap(); let user = User::new(msg.chat.username().unwrap().to_string(), msg.chat.id); users.insert(user); } “/status” => { bot.send_message(msg.chat.id, TEXT2).await.unwrap(); } &_ => {} }; Ok(()) […]

I learn Rust language with a book “Programming Rust 2nd Edition”.
I wrote the codes for requesting many requests included chapter asynchronous programming as I wish.