Function keep_alive_stream 

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