Function re_analytics::native::pipeline::realtime_pipeline

fn realtime_pipeline(
    config: &Config,
    sink: &PostHogSink,
    session_file: File,
    tick: Duration,
    event_tx: &Sender<Result<AnalyticsEvent, RecvError>>,
    event_rx: &Receiver<Result<AnalyticsEvent, RecvError>>,
    abort_signal: &AbortSignal
)