Hey all, i just started learning rust and completed the basics of it. and also built some beginner friendly project in it with help of chatgpt and ai. Now i am building another project for learning and get hands dirty in rust.

Just look into below code.

// it is used to listen incoming TCP connections asynchronously.
// it is non-blocking and works with async/await
use tokio::net::TcpListener; 


// together these allow you to read from async stream line by line efficiently
// BufReader :- Wraps a reader and provide buffering
//              Helps reduce the number of .await I/O calls by buffering the input
// 
// AsyncBufReadExt :- A trait that adds methods like read_lines() and lines() 
use tokio::io::{AsyncBufReadExt, BufReader}; 
use std::error::Error;


#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    // Bind to connection on port 6379
    println!("Redis-lite server starting...");
    let listener = TcpListener::bind("127.0.0.1:6379").await?;
    println!("Redis-lite server listening on 6379...");
    
    loop {
        // Accept a new client connection
        let (socket, addr) = listener.accept().await?;
        println!("new client connected: {}", addr);
        
        // just spawn a task as of now.
        
        tokio::spawn(async move {
            let reader = BufReader::new(socket);
            let mut lines = reader.lines();
            
            while let Ok(Some(line)) = lines.next_line().await {
                println!("Received from {}: {}", addr, line);
            }
            
            println!("Client {} disconnected", addr);
        });
    }
}

can anyone help me and explain me what each things gonna work with appropriate example. I want deep explanation and understanding of the things in rust.

6 posts - 3 participants

Read full topic