fn initial_bases<'a>( services: &'a Services, rooms: &'a [OwnedRoomId], filter: &'a FilterDefinition, ) -> impl Stream<Item = Result<Input>> + Send + 'a