Skip to content

Commit

Permalink
Improve and tidy up comments in core
Browse files Browse the repository at this point in the history
  • Loading branch information
twright committed Nov 13, 2024
1 parent f95ea47 commit 3fa60cb
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions src/core.rs
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,11 @@ impl Display for Value {
}
}

/* Trait for the values being sent along streams. This could be just Value for
* untimed heterogeneous streams, more specific types for homogeneous (typed)
* streams, or time-stamped values for timed streams. This traits allows
* for the implementation of runtimes to be agnostic of the types of stream
* values used. */
pub trait StreamData: Clone + Send + Sync + Debug + 'static {}

// Trait defining the allowed types for expression values
Expand Down Expand Up @@ -159,8 +164,6 @@ pub trait StreamContext<Val: StreamData>: Send + 'static {
}

pub trait MonitoringSemantics<Expr, Val, CVal = Val>: Clone + Send + 'static {
// type ExpressionTyping: ExpressionTyping<TypeSystem = <Self::StreamSystem as StreamSystem>::TypeSystem>;

fn to_async_stream(expr: Expr, ctx: &dyn StreamContext<CVal>) -> OutputStream<Val>;
}

Expand Down

0 comments on commit 3fa60cb

Please sign in to comment.