reifydb-sub-flow 0.5.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: Apache-2.0
// Copyright (c) 2025 ReifyDB

use std::any::Any;

use reifydb_type::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,
}