Function receive_feed 

pub async fn receive_feed(
    db: &Db,
    producer: &str,
    from: i64,
    entries: &[FeedEntry],
) -> Result<()>

A consumer racing from the same cursor fails as Conflict. Before any worker is published, entries wait as events; one no listener hears is dropped with a warning after an hour.