Struct GpsdClientCore 

pub struct GpsdClientCore<Stream, Proto> { /* private fields */ }

Core implementation of a blocking GPSD client

This struct provides the fundamental functionality for synchronous communication with a GPSD server. It handles protocol negotiation, message serialization/deserialization, and maintains the connection state.

Type Parameters

• Stream - The underlying I/O stream type (e.g., TcpStream)
• Proto - The GPSD protocol version implementation

Implementations

impl<Stream, Proto> GpsdClientCore<Stream, Proto>

where Proto: GpsdJsonProtocol,

pub fn open(stream: Stream) -> Result<Self>

where Stream: Read + Write,

Opens a new GPSD client connection using the provided stream

This method initializes the client with the given I/O stream and performs protocol version negotiation with the GPSD server.

Arguments

• stream - The I/O stream for communication with GPSD

Returns

• Ok(client) - Successfully connected and negotiated protocol
• Err(_) - Connection or protocol negotiation failed

impl<Proto> GpsdClientCore<TcpStream, Proto>

where Proto: GpsdJsonProtocol,

pub fn connect<A: ToSocketAddrs>(addr: A) -> Result<Self>

Connects to a GPSD server over TCP

Creates a TCP connection to the specified address and initializes a GPSD client with protocol negotiation.

Arguments

• addr - Socket address of the GPSD server (e.g., “127.0.0.1:2947”)

Returns

• Ok(client) - Successfully connected to GPSD
• Err(_) - Connection failed or protocol negotiation failed

Example

let client = GpsdClient::connect("127.0.0.1:2947").unwrap();

impl<Stream> GpsdClientCore<Stream, V3>

where Stream: Read + Write,

pub fn version(&mut self) -> Result<Version>

Requests version information from the GPSD server

Returns details about the GPSD server version, protocol version, and capabilities.

pub fn devices(&mut self) -> Result<DeviceList>

Lists all GPS devices known to the GPSD server

Returns information about each connected GPS receiver including device paths, driver information, and current status.

pub fn device(&mut self) -> Result<Device>

Gets information about the currently active GPS device

Returns detailed information about the device currently being used for GPS data.

pub fn watch(&mut self) -> Result<(Watch, DeviceList)>

Enables data streaming from GPSD with default settings

Returns the current watch configuration and list of available devices. After calling this method, GPS data will be streamed from the server.

pub fn poll(&mut self) -> Result<Poll>

Polls for the current GPS fix data

Returns the most recent GPS fix information available from all active devices.

pub fn watch_mode(&mut self, enable: bool) -> Result<()>

Enables or disables data streaming mode

Arguments

• enable - true to start streaming, false to stop

pub fn stream<Format: StreamFormat>( self, opts: StreamOptions<Format>, ) -> Result<GpsdDataStream<Stream, V3, Format>>

Starts a data stream with the specified format and options

This method consumes the client and returns a stream iterator that yields GPS data in the requested format.

Arguments

• opts - Stream configuration options

Example

let stream = client.stream(StreamOptions::json()).unwrap();

Trait Implementations

impl<Stream: Debug, Proto: Debug> Debug for GpsdClientCore<Stream, Proto>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Proto> TryFrom<TcpStream> for GpsdClientCore<TcpStream, Proto>

where Proto: GpsdJsonProtocol,

type Error = GpsdJsonError

The type returned in the event of a conversion error.

fn try_from(stream: TcpStream) -> Result<Self>

Performs the conversion.