current.rs

fn main() -> io::Result<()> {
    executor::block_on(async {
        let listener = TcpListener::bind(&"127.0.0.1:7878".parse().unwrap())?;
        let mut incoming = listener.incoming();
        while let Some(stream) = await!(incoming.next()) {
            let stream = stream?;
            let addr = stream.peer_addr()?;

            juliex::spawn(async move {
                let (mut reader, mut writer) = stream.split();
                await!(reader.copy_into(&mut writer)).unwrap(); // Just unwrap?
            });
        }
        Ok(())
    })
}

future.rs

async fn main() -> io::Result<()> {
  let listener = TcpListener::bind(&"127.0.0.1:7878".parse()?)?;

  #[parallel]
  for await stream? in listener.incoming() {
    let (mut reader, mut writer) = stream.split();
    await reader.copy_into(&mut writer)?;
  }

  Ok(())
}