start adding framework for pipelines

1 files changed, 5 insertions, 0 deletions

diff --git a/src/main.rs b/src/main.rs
index 602eb8e..b5b1f09 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -16,6 +16,7 @@ mod env;
 mod event;
 mod format;
 mod parse;
+mod pipe;
 mod state;
 
 use async_std::stream::StreamExt as _;
@@ -135,6 +136,10 @@ async fn async_main() -> anyhow::Result<()> {
 }
 
 fn main() {
+    if std::env::args().nth(1).as_deref() == Some("--internal-pipe-runner") {
+        pipe::run();
+        std::process::exit(0);
+    }
     match async_std::task::block_on(async_main()) {
         Ok(_) => (),
         Err(e) => {