use std::io::{self, BufRead, Write};
fn main() {
let stdin = io::stdin();
let mut reader = stdin.lock();
let stdout = io::stdout();
let mut writer = stdout.lock();
loop {
let mut message = String::new();
reader.read_line(&mut message).expect("Failed to read line");
let response = process_message(&message);
writer.write_all(response.as_bytes()).expect("Failed to write response");
writer.flush().expect("Failed to flush");
}
}
fn process_message(message: &str) -> String {
// Implement your logic to process messages here
// You can use serde for JSON serialization/deserialization
// Example: Convert message to JSON and return a response
let response = format!("{{\"result\": \"Processed: {}\"}}", message.trim());
response
}
use std::io::{self, BufRead, Write};
fn main() {
let stdin = io::stdin();
let mut reader = stdin.lock();
let stdout = io::stdout();
let mut writer = stdout.lock();
loop {
let mut message = String::new();
reader.read_line(&mut message).expect("Failed to read line");
let response = process_message(&message);
writer.write_all(response.as_bytes()).expect("Failed to write response");
writer.flush().expect("Failed to flush");
}
}
fn process_message(message: &str) -> String {
// Implement your logic to process messages here
// You can use serde for JSON serialization/deserialization
// Example: Convert message to JSON and return a response
let response = format!("{{\"result\": \"Processed: {}\"}}", message.trim());
response
}