diff options
| author | tv <tv@krebsco.de> | 2026-10-31 04:50:14 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 04:50:14 +0100 |
| commit | a8d6adcea38051e1edba4387ac4db9a48285db0f (patch) | |
| tree | ffa4dd7fece708b95d387d91884739d20eab1d85 /src/transport/sim.rs | |
| parent | 6e0a3fc86fcd3df3d0b26469f132602c7dce9c24 (diff) | |
unify wire encoder
Diffstat (limited to 'src/transport/sim.rs')
| -rw-r--r-- | src/transport/sim.rs | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/src/transport/sim.rs b/src/transport/sim.rs index 9267232..f4a48aa 100644 --- a/src/transport/sim.rs +++ b/src/transport/sim.rs @@ -273,15 +273,7 @@ pub(crate) const WIRE: Codec = Codec { }; fn wire_encode(peer: &str, message: &ParsedMessage) -> Result<EncodedMessage> { - let body = super::wire::encode(message)?; - Ok(EncodedMessage { - peer: peer.to_owned(), - address: peer.to_owned(), - payload_len: body.len(), - body: body.into(), - kind: message.kind(), - message: None, - }) + super::wire::encoded(peer, message) } fn wire_decode(body: &[u8]) -> Result<ParsedMessage> { |
