Struct JsonArrayStreamFormat 

pub struct JsonArrayStreamFormat<E = ()>
where
    E: Serialize,
{ /* private fields */ }

Available on crate feature json only.

A JSON array: [item, item, …], optionally wrapped in an envelope object.

Implementations

impl JsonArrayStreamFormat

pub fn new() -> JsonArrayStreamFormat<()>

A bare array.

pub fn with_envelope<E>( envelope: E, array_field: &str, ) -> JsonArrayStreamFormat<E>

where E: Serialize,

An array emitted as array_field of envelope.

Encode only: the decoder expects a bare array and will not unwrap an envelope.

Trait Implementations

impl<E> Clone for JsonArrayStreamFormat<E>

where E: Serialize + Clone,

fn clone(&self) -> JsonArrayStreamFormat<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E> Debug for JsonArrayStreamFormat<E>

where E: Serialize + Debug,

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

Formats the value using the given formatter.

impl Default for JsonArrayStreamFormat<()>

fn default() -> Self

Returns the “default value” for a type.

impl DefaultFormat for JsonArrayStreamFormat<()>

fn default_format() -> Self

The configuration to use when the caller supplied none.

impl<E> StreamFormat for JsonArrayStreamFormat<E>

where E: Serialize,

fn format_name(&self) -> &'static str

A short, stable name, reported as the format tracing field.

fn default_content_type(&self) -> &'static str

The Content-Type this format emits when encoding.

fn accepts_content_type(&self, ct: &ContentType<'_>) -> bool

Whether an incoming Content-Type should be accepted as this format.

impl<T, E> StreamFormatDecode<T> for JsonArrayStreamFormat<E>

where T: for<'de> Deserialize<'de>, E: Serialize,

type Frame = Result<T, StreamError>

One framed record, before deserialisation.

type Framer = JsonArrayCodec<T>

Splits the body into records.

type Parser = IdentityParser

Deserialises framed records.

fn framer(&self, options: &DecodeOptions) -> Self::Framer

Build a framer for one body.

fn parser(&self) -> Self::Parser

Build a parser for one body.

impl<T, E> StreamFormatEncode<T> for JsonArrayStreamFormat<E>

where T: Serialize, E: Serialize,

type Encoder = JsonArrayEncoder

The per-stream encoder. A fresh one is built for every body, because framing state (item index, Arrow’s dictionary tracker, CSV’s header flag) is per-stream.

fn encoder(&self) -> Self::Encoder

Build an encoder for one body.