Function run

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>

Run message lane service loop.