service_flows/
service_flows.rs

1use flarrow_layout::prelude::*;
2
3use flarrow_flows::prelude::{thirdparty::*, *};
4
5#[tokio::main]
6async fn main() -> Result<()> {
7    let mut layout = DataflowLayout::new();
8
9    let (_service, queryable) = layout
10        .node("service", async |builder: &mut NodeIOBuilder| {
11            builder.queryable("queryable")
12        })
13        .await;
14
15    let (_client, query) = layout
16        .node("client", async |builder: &mut NodeIOBuilder| {
17            builder.query("query")
18        })
19        .await;
20
21    let layout = layout.build();
22
23    let _flows = Flows::new(layout.clone(), async move |builder: &mut FlowsBuilder| {
24        builder.connect(query, queryable, None)?;
25
26        Ok(())
27    })
28    .await?;
29
30    Ok(())
31}