1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
// Released under the MIT License.
// Copyright, 2026, by Samuel Williams.
use crate::{BufferPool, BufferPooling, SocketOperation, SocketPacketReader, SocketRecvMessageMut};
use std::io;
/// Construct sequential packet input bound to this scheduler. Backends choose the static reader and completed message representation without exposing their receive mechanism.
///
/// The returned handle may borrow the scheduler, but never the temporary socket
/// reference. It retains backend access independently, so the socket and handle
/// can move together. Retire and drop handles before exclusively closing the socket.
pub trait SocketPacketReading: SocketOperation + BufferPooling {
/// Retain the socket and reusable backend state without submitting a receive or allocating a payload pool. Owned reads initialize default storage lazily.
fn socket_packet_reader<'scheduler>(
&'scheduler self,
socket: &Self::Socket,
) -> io::Result<
impl SocketPacketReader<
Message: SocketRecvMessageMut<Payload = <Self::Pool as BufferPool>::Buffer>,
>
+ 'scheduler
+ use<'scheduler, Self>,
>
where
Self: Sized,
Self::Socket: 'static;
/// Construct a reader using the supplied pool for owned messages. Borrowed reads do not acquire pool storage; completed messages retain their pool independently.
fn socket_packet_reader_with_pool<'scheduler>(
&'scheduler self,
socket: &Self::Socket,
pool: Self::Pool,
) -> io::Result<
impl SocketPacketReader<
Message: SocketRecvMessageMut<Payload = <Self::Pool as BufferPool>::Buffer>,
>
+ 'scheduler
+ use<'scheduler, Self>,
>
where
Self: Sized,
Self::Socket: 'static;
}