[[RACObserve(self, type) distinctUntilChanged] subscribeNext:^(id x) {

        @strongify(self);

        self.query.pageIndex = 1;

        [self loadDataSource];

    }];

distinctUntilChanged 

也是一个相当常用的Filter（但它不是- filter:的衍生方法），它将这一次的值与上一次做比较，当相同时（也包括- isEqual:）被忽略掉。