aarondb/reactive
Types
pub type ReactiveMessage {
Subscribe(
query: ast.Query,
attributes: List(String),
subscriber: process.Subject(query_types.ReactiveDelta),
initial_state: query_types.QueryResult,
)
Notify(
changed_attributes: List(String),
current_state: state.DbState,
)
}Constructors
-
Subscribe( query: ast.Query, attributes: List(String), subscriber: process.Subject(query_types.ReactiveDelta), initial_state: query_types.QueryResult, ) -
Notify( changed_attributes: List(String), current_state: state.DbState, )
Values
pub fn start_link() -> Result(
process.Subject(state.ReactiveMessage),
actor.StartError,
)