Lightws
Lightweight websocket implement for stream transmission.
Features
- Avoid heap allocation.
- Avoid buffering frame payload.
- Use vectored-io if available.
- Transparent Read/Write over the underlying IO source.
High-level API
[role, endpoint, stream]
Std:
{
// handshake
let stream = Endpoint<TcpStream, Client>::connect(tcp, buf, host, path)?;
// read some data
stream.read(&mut buf)?;
// write some data
stream.write(&buf)?;
}
Async:
{
// handshake
let stream = Endpoint<TcpStream, Client>::connect_async(tcp, buf, host, path).await?;
// read some data
stream.read(&mut buf).await?;
// write some data
stream.write(&buf).await?;
}
Low-level API
[frame, handshake]
Frame:
{
// encode a frame head
let head = FrameHead::new(...);
let offset = unsafe {
head.encode_unchecked(&mut buf);
};
// decode a frame head
let (head, offset) = FrameHead::decode(&buf).unwrap();
}
Handshake:
{
// make a client handshake request
let request = Request::new(b"/ws", b"example.com", "sec-key..");
let offset = request.encode(&mut buf).unwrap();
// parse a server handshake response
let mut custom_headers = HttpHeader::new_storage();
let mut response = Response::new_storage(&mut custom_headers);
let offset = response.decode(&buf).unwrap();
}
1 Feb 11, 2022
2 Aug 27, 2022
5 Dec 21, 2022
5 Apr 2, 2023
1.3k Jan 8, 2023
1.3k Jan 2, 2023
294 Dec 23, 2022
1.3k Dec 30, 2022
4 Aug 14, 2024
4 Feb 26, 2022
94 Dec 30, 2022
94 Dec 30, 2022
7 Dec 16, 2022
33 Dec 29, 2022
43 Nov 19, 2022
70 Jan 7, 2023
21 Aug 23, 2022
1 Oct 23, 2021
94 Dec 30, 2022
94 Dec 30, 2022
1.3k Jan 6, 2023
13 Oct 28, 2022
622 Dec 26, 2022
91 Jan 5, 2023
19 Aug 22, 2022
8 Sep 7, 2022
1 Feb 14, 2022
261 Dec 27, 2022