Struct Queryable

pub struct Queryable<T: ArrowMessage, F: ArrowMessage> {
    pub raw: RawQueryable,
    /* private fields */
}

Typed Queryable to queryable data to the dataflow

Fields

raw: RawQueryable

Implementations

impl<T: ArrowMessage, F: ArrowMessage> Queryable<T, F>

pub fn new( tx: HashMap<Uuid, MessageSender>, rx: MessageReceiver, clock: Arc<HLC>, source: NodeLayout, layout: QueryableLayout, ) -> Self

Create a new typed Queryable

pub fn blocking_on_demand( &mut self, response: impl FnOnce(T) -> Result<F>, ) -> Result<()>

Let the queryable handle a message, converting it from Arrow format, blocking until one is available, don’t use it in async context

pub async fn on_demand( &mut self, response: impl AsyncFnOnce(T) -> Result<F>, ) -> Result<()>

Let the queryable handle a message, converting it from Arrow format, asynchrously