阿克卡河。组合物化值。需要绘制未来地图。要使用哪个ExecutionContext/Dispatcher?

鉴于:

• AtoB: GraphStageWithMaterializedValue[A, B, Future[AtoBRuntimeApi]] ;

• BtoC: GraphStageWithMaterializedValue[B, C, Future[BtoCRuntimeApi]] .

通缉犯: AtoC: GraphStageWithMaterializedValue[A, C, Future[AtoCRuntimeApi]] .

在我的特殊情况下,实现起来非常方便 AtoCRuntimeApi 就两者而言 AtoBRuntimeApi 和 BtoARuntimeApi .

所以我想定义一下 AtoCRuntimeApi公司 像 case class AtoCRuntimeApi(a2b: AtoBRuntimeApi, b2c: BtoCRuntimeApi) ;

并将新的复合阶段定义为 stageAtoB.viaMat(stageBtoC)(combineIntoAtoC) 哪里 combineIntoAtoC: (Future[AtoBRuntimeApi], Future[B2CRuntimeApi]) => Future[AtoCRuntimeApi] .

显然 combineIntoAtoC 需要的某些实例 ExecutionContext 为了描绘未来。

问题:在所描述的案例中,我应该使用什么执行上下文?

选择,我宁愿避免:

• 在当前可用的实例中烘焙(阶段组成时),如果执行上下文变得不可用,“蓝图”将无法安全实现;

• ExecutionContext.global 嗯,这是全球性的。使用它似乎大错特错(可能,每次实现一次也没什么大不了的)。

最需要的执行上下文是作为materializer属性可用的上下文( mat.executionContext ). 但我无法在联合收割机功能中访问它。