Skip to content

Commit

Permalink
src: stream: Only start the pipeline after every sink has connected
Browse files Browse the repository at this point in the history
  • Loading branch information
joaoantoniocardoso authored and patrickelectric committed Apr 19, 2023
1 parent 1fb22c9 commit c0bd65b
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions src/stream/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -96,6 +96,13 @@ impl Stream {
));
}

// Start the pipeline. This will automatically start sinks with linked proxy-isolated pipelines
stream
.pipeline
.inner_state_as_ref()
.pipeline_runner
.start()?;

Ok(stream)
}
}
Expand Down

0 comments on commit c0bd65b

Please sign in to comment.