Struct RecordingCodec 

pub struct RecordingCodec<C> { /* private fields */ }

A Codec decorator that records every byte crossing the wire.

Outbound bytes are recorded after a successful encode (empty encodes — e.g. SessionCommand::Disconnect — are skipped because they never hit the wire). Inbound bytes are recorded before decoding, so frames that fail to decode are still captured.

use std::sync::Arc;
use gemini_genai_rs::transport::{JsonCodec, MemoryWireRecorder, RecordingCodec};

let recorder = Arc::new(MemoryWireRecorder::new());
let codec = RecordingCodec::new(JsonCodec, recorder.clone());

Implementations

impl<C: Codec> RecordingCodec<C>

pub fn new(inner: C, recorder: Arc<dyn WireRecorder>) -> Self

Wrap inner, delivering taps to recorder.

Trait Implementations

impl<C: Codec> Codec for RecordingCodec<C>

fn encode_setup(&self, config: &SessionConfig) -> Result<Vec<u8>, CodecError>

Encode the initial setup message for the given session configuration.

fn encode_command( &self, cmd: &SessionCommand, config: &SessionConfig, ) -> Result<Vec<u8>, CodecError>

Encode a session command into wire bytes.

fn decode_message(&self, data: &[u8]) -> Result<ServerMessage, CodecError>

Decode raw bytes from the server into a ServerMessage.