zip should use RACGenericReduceBlock. Reduce blocks are mandatory.

Author: andersio

ReactiveObjC/RACSignal+Operations.m

@@ -456,7 +456,7 @@ + (RACSignal *)combineLatest:(id<NSFastEnumeration>)signals {
 	}] setNameWithFormat:@"+combineLatest: %@", signals];
 }
 
-+ (RACSignal *)combineLatest:(id<NSFastEnumeration>)signals reduce:(id (^)())reduceBlock {
++ (RACSignal *)combineLatest:(id<NSFastEnumeration>)signals reduce:(RACGenericReduceBlock)reduceBlock {
 	NSCParameterAssert(reduceBlock != nil);
 
 	RACSignal *result = [self combineLatest:signals];

ReactiveObjC/RACSignal.h

@@ -268,7 +268,7 @@ typedef RACSignal * _Nullable (^RACSignalBindBlock)(ValueType _Nullable value, B
 ///
 /// Returns a new signal containing the results from each invocation of
 /// `reduceBlock`.
-+ (RACSignal<ValueType> *)zip:(id<NSFastEnumeration>)signals reduce:(RACReduceBlock)reduceBlock RAC_WARN_UNUSED_RESULT;
++ (RACSignal<ValueType> *)zip:(id<NSFastEnumeration>)signals reduce:(RACGenericReduceBlock)reduceBlock RAC_WARN_UNUSED_RESULT;
 
 /// Returns a signal obtained by concatenating `signals` in order.
 + (RACSignal<ValueType> *)concat:(id<NSFastEnumeration>)signals RAC_WARN_UNUSED_RESULT;

ReactiveObjC/RACStream.h

@@ -23,8 +23,8 @@ NS_ASSUME_NONNULL_BEGIN
 
 _Pragma("clang diagnostic push") \
 _Pragma("clang diagnostic ignored \"-Wstrict-prototypes\"") \
-typedef id _Nullable (^RACReduceBlock)();
-typedef ValueType _Nullable (^RACGenericReduceBlock)();
+typedef id _Nonnull (^RACReduceBlock)();
+typedef ValueType _Nonnull (^RACGenericReduceBlock)();
 _Pragma("clang diagnostic pop")
 
 /// Returns an empty stream.
@@ -227,7 +227,7 @@ typedef RACStream * _Nullable (^RACStreamBindBlock)(ValueType _Nullable value, B
 ///
 /// Returns a new stream containing the results from each invocation of
 /// `reduceBlock`.
-+ (__kindof RACStream<ValueType> *)zip:(id<NSFastEnumeration>)streams reduce:(RACReduceBlock)reduceBlock;
++ (__kindof RACStream<ValueType> *)zip:(id<NSFastEnumeration>)streams reduce:(RACGenericReduceBlock)reduceBlock;
 
 /// Returns a stream obtained by concatenating `streams` in order.
 + (__kindof RACStream<ValueType> *)concat:(id<NSFastEnumeration>)streams;

ReactiveObjC/RACStream.m

@@ -139,7 +139,7 @@ - (__kindof RACStream *)ignore:(id)value {
 	}] setNameWithFormat:@"[%@] -ignore: %@", self.name, RACDescription(value)];
 }
 
-- (__kindof RACStream *)reduceEach:(id (^)())reduceBlock {
+- (__kindof RACStream *)reduceEach:(RACReduceBlock)reduceBlock {
 	NSCParameterAssert(reduceBlock != nil);
 
 	__weak RACStream *stream __attribute__((unused)) = self;
@@ -234,7 +234,7 @@ + (__kindof RACStream *)zip:(id<NSFastEnumeration>)streams {
 	}] setNameWithFormat:@"+zip: %@", streams];
 }
 
-+ (__kindof RACStream *)zip:(id<NSFastEnumeration>)streams reduce:(id (^)())reduceBlock {
++ (__kindof RACStream *)zip:(id<NSFastEnumeration>)streams reduce:(RACGenericReduceBlock)reduceBlock {
 	NSCParameterAssert(reduceBlock != nil);
 
 	RACStream *result = [self zip:streams];