pub fn repeat<'a, Item>(x: Item) -> Observable<'a, Item>where
    Item: Clone + Send + Sync,