From c800b597cd8c1ce87d6edaab7347c43ccdd48a93 Mon Sep 17 00:00:00 2001 From: Santiago Carmuega Date: Sun, 3 Mar 2024 20:40:27 -0300 Subject: [PATCH] fix: apply unix flag to n2c source --- src/sources/mod.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/sources/mod.rs b/src/sources/mod.rs index bed3d715..35410cd6 100644 --- a/src/sources/mod.rs +++ b/src/sources/mod.rs @@ -17,6 +17,8 @@ pub mod utxorpc; pub enum Bootstrapper { N2N(n2n::Stage), + + #[cfg(target_family = "unix")] N2C(n2c::Stage), #[cfg(feature = "aws")] @@ -30,6 +32,8 @@ impl Bootstrapper { pub fn borrow_output(&mut self) -> &mut SourceOutputPort { match self { Bootstrapper::N2N(p) => &mut p.output, + + #[cfg(target_family = "unix")] Bootstrapper::N2C(p) => &mut p.output, #[cfg(feature = "aws")] @@ -43,6 +47,8 @@ impl Bootstrapper { pub fn spawn(self, policy: gasket::runtime::Policy) -> Tether { match self { Bootstrapper::N2N(x) => gasket::runtime::spawn_stage(x, policy), + + #[cfg(target_family = "unix")] Bootstrapper::N2C(x) => gasket::runtime::spawn_stage(x, policy), #[cfg(feature = "aws")] @@ -73,6 +79,8 @@ impl Config { pub fn bootstrapper(self, ctx: &Context) -> Result { match self { Config::N2N(c) => Ok(Bootstrapper::N2N(c.bootstrapper(ctx)?)), + + #[cfg(target_family = "unix")] Config::N2C(c) => Ok(Bootstrapper::N2C(c.bootstrapper(ctx)?)), #[cfg(feature = "aws")]