Function keep_alive_stream 

pub fn keep_alive_stream(
    pool: SqlitePool,
    config: Config,
    worker: WorkerContext,
) -> impl Stream<Item = Result<(), Error>> + Send

Create a stream that sends keep-alive signals at regular intervals