Struct StreamerValue 

pub struct StreamerValue {
    pub text: String,
    pub ast: Comprehension,
    pub outer: Vec<String>,
}

A comprehension bound as a value.

Fields

text: String

The text after for, as the author wrote it (or, for a derived producer, the derivation text).

ast: Comprehension

The comprehension, with any derivation already applied.

outer: Vec<String>

The names the comprehension reads from the scope its wire is bound in: each is a name of that scope, which a traversal captures when it opens and a stream has none of. Empty for a streamer built from text alone.

Implementations

impl StreamerValue

pub fn new(text: impl Into<String>, ast: Comprehension) -> Self

A streamer over ast with its source text, bound in no scope.

pub fn in_scope( text: impl Into<String>, ast: Comprehension, has: &dyn Fn(&str) -> bool, ) -> Self

A streamer over ast bound to a wire of a scope that has the names has answers true for. Self::outer holds the names the comprehension reads, does not bind, and the scope has; a name it reads that the scope does not have is resolved nowhere and reads None (comprehension_forms.md §5 V3).

pub fn element_names(&self) -> Vec<String>

Element names in tuple order.

pub fn metadata(&self) -> Metadata

The algebra’s metadata: cardinality, index addressability, and natural order.

pub fn cardinality(&self) -> CardinalityClass

The cardinality class of the tuple space.

pub fn compiled(&self) -> Result<CompiledComprehension, ValidationError>

Compile to the shared IR: validation, optimization, then the AST → IR pass. Each call is independent. A comprehension the for lowering resolved was validated then and fails here only when it reads a name of the scope its wire is bound in (Self::outer), which this surface has none of (ContextRequired, PredicateContextRequired, comprehension_forms.md §9.5.2); one built programmatically is validated here. A name it reads that nothing binds reads None (§5 V3).

pub fn coordinate_stream(&self) -> Result<CoordinateStream, ValidationError>

A fresh coordinate stream with its own dispense cursor.

pub fn to_json(&self) -> String

Serialize for transport through a const node argument. The compiler lowers a producer binding to streamer("<json>").

pub fn from_json(payload: &str) -> Self

Build from a node argument: either the JSON payload the compiler emits for for expressions, or plain comprehension text such as k in 1..4 when an author calls streamer directly. Panics with the parser’s diagnostic when neither form applies.

pub fn parse_text(text: &str) -> Result<Self, String>

Parse canonical comprehension text into a streamer value.

Trait Implementations

impl Clone for StreamerValue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamerValue

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamerValue

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StreamerValue

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl ReflectedValue for StreamerValue

fn type_name(&self) -> &str

Type name for diagnostics and describe output.

fn display(&self) -> String

Human-readable string representation. Used by stdout adapter, logging, and diagnostics.

fn to_json_value(&self) -> Value

JSON representation for serialization and HTTP bodies.

fn as_any(&self) -> &dyn Any

Downcast to the concrete type. Only works when the consuming code has the concrete type in scope (same crate or shared dep).

fn clone_reflected(&self) -> Box<dyn ReflectedValue>

Clone into a new boxed trait object.

fn try_as_str(&self) -> Option<String>

Try to represent as a string. Many types have a canonical string form (UUIDs, timestamps, IP addresses).

fn try_as_u64(&self) -> Option<u64>

Try to represent as u64.

fn try_as_f64(&self) -> Option<f64>

Try to represent as f64.

fn try_as_bytes(&self) -> Option<&[u8]>

Try to represent as bytes.

impl Serialize for StreamerValue

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for StreamerValue