Struct Queryable 

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

Typed Queryable to queryable data to the dataflow

Fields

raw: RawQueryable

Implementations

impl<T, F> Queryable<T, F>

where T: ArrowMessage, F: ArrowMessage,

pub fn new( tx: HashMap<Uuid, Sender<DataflowMessage>>, rx: Receiver<DataflowMessage>, clock: Arc<HLC>, source: NodeLayout, layout: QueryableLayout, ) -> Queryable<T, F>

Create a new typed Queryable

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

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, Report>, ) -> Result<(), Report>

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