Skip to main content

Module data_stream

Module data_stream 

Source
Expand description

Runtime-owned streams for large binary data.

Large data should not travel through action payloads or capability results as Vec<u8>. Host capabilities register streams here, then reducers pass the returned DataStreamId to jobs or services that consume the stream asynchronously.

Structs§

DataStreamId
Unique identifier for a runtime-owned binary stream.
DataStreamRegistry
Host/runtime registry for one-shot data streams.
FissionDataStreamError
Error item yielded by FissionDataStream.

Enums§

FissionDataStreamErrorKind
Machine-readable class of stream failure.

Traits§

FissionDataStream
Fission’s framework-wide stream trait for large binary payloads.

Functions§

collect_data_stream
Collects a data stream into one contiguous byte buffer.
empty_data_stream
Creates an empty stream.
single_chunk_data_stream
Creates a stream that yields a single byte chunk.

Type Aliases§

BoxFissionDataStream
Boxed dynamic Fission data stream.