reifydb-sub-flow 0.6.0

Flow subsystem for stream processing and data flows
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

// SPDX-License-Identifier: AGPL-3.0-or-later
// Copyright (c) 2026 ReifyDB

use std::any::Any;

use reifydb_value::Result;

use super::FlowTransaction;

pub type PersistFn = Box<dyn FnOnce(&mut FlowTransaction, Box<dyn Any>) -> Result<()> + Send>;

pub struct OperatorStateSlot {
	pub value: Box<dyn Any + Send>,
	pub dirty: bool,
	pub persist: PersistFn,
}