service_flows/
service_flows.rs

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