Struct JsonReader 

pub struct JsonReader { /* private fields */ }

Owned, ergonomic handle over an erased JsonBufferReader.

Returned by subscribe_json. Awaiting recv_json or recv_json_bytes wraps the corresponding poll method via core::future::poll_fn — no extra per-message future box.

Implementations

impl JsonReader

pub fn new(inner: Box<dyn JsonBufferReader + Send>) -> Self

Wrap an erased JSON reader in an ergonomic handle.

pub async fn recv_json(&mut self) -> Result<Value, DbError>

Receive the next value as JSON, awaiting until one is available.

pub async fn recv_json_bytes(&mut self) -> Result<Vec<u8>, DbError>

Receive the next value as owned JSON bytes.

pub fn try_recv_json(&mut self) -> Result<Value, DbError>

Non-blocking receive as JSON — returns immediately.

Returns Err(DbError::BufferEmpty) if no pending values.

pub fn try_recv_json_bytes(&mut self) -> Result<Vec<u8>, DbError>

Non-blocking receive as owned JSON bytes — returns immediately.

Returns Err(DbError::BufferEmpty) if no pending values.