Function messages_relay::message_lane_loop::run
source · pub async fn run<P: MessageLane>(
params: Params<P::LaneId>,
source_client: impl SourceClient<P>,
target_client: impl TargetClient<P>,
metrics_params: MetricsParams,
exit_signal: impl Future<Output = ()> + Send + 'static,
) -> Result<(), Error>
Expand description
Run message lane service loop.