interprocess 2.2.2

Interprocess communication toolkit
Documentation 
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

use super::*;
use std::fmt::{self, Debug, DebugStruct, Formatter};

impl RawPipeStream {
	#[allow(clippy::as_conversions)]
	fn fill_fields<'a, 'b, 'c>(
		&self,
		dbst: &'a mut DebugStruct<'b, 'c>,
		recv_mode: Option<PipeMode>,
		send_mode: Option<PipeMode>,
	) -> &'a mut DebugStruct<'b, 'c> {
		let (tokio_object, is_server) = match self.inner() {
			InnerTokio::Server(s) => (s as _, true),
			InnerTokio::Client(c) => (c as _, false),
		};
		if let Some(recv_mode) = recv_mode {
			dbst.field("recv_mode", &recv_mode);
		}
		if let Some(send_mode) = send_mode {
			dbst.field("send_mode", &send_mode);
		}
		dbst.field("tokio_object", tokio_object)
			.field("is_server", &is_server)
	}
}

impl<Rm: PipeModeTag, Sm: PipeModeTag> Debug for PipeStream<Rm, Sm> {
	fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
		let mut dbst = f.debug_struct("PipeStream");
		self.raw.fill_fields(&mut dbst, Rm::MODE, Sm::MODE);
		if Sm::MODE.is_some() {
			dbst.field("flusher", &self.flusher);
		}
		dbst.finish()
	}
}