BatchProxy fixes - passing basic test

ActorKit/ActorKit.h

@@ -10,6 +10,7 @@
 #import "BatchProxy.h"
 #import "SyncProxy.h"
 #import "NSObject+Actor.h"
+#import "NSArray+Actor.h"
 
 // private
 

ActorKit/BatchProxy.m

@@ -49,21 +49,25 @@ - (void)forwardInvocation:(NSInvocation *)anInvocation
 		  NSStringFromSelector([anInvocation selector])]];
 	}
 
-	NSInteger length = [batchTarget length];
-	id *results = calloc(0, sizeof(id) * length);
-
 	[anInvocation retainArguments];
-
+
+	NSInteger length = [batchTarget count];
+	id *results = calloc(0, sizeof(id) * length);
+
 	dispatch_apply(length, [self batchDispatchQueue], 
 		^(size_t i)
 		{
+			//printf("start %i\n", (int)i);
 			id item = [batchTarget objectAtIndex:i];
 			NSInvocation *copyInvocation = [anInvocation copy];
+			[copyInvocation retain];
 			[copyInvocation invokeWithTarget:item];
 
 			id r;
 			[copyInvocation getReturnValue:&r];
 			results[i] = r;
+			[copyInvocation release];
+			//printf("end %i\n", (int)i);
 		}
 	);
 
@@ -77,7 +81,14 @@ - (void)forwardInvocation:(NSInvocation *)anInvocation
 
 - (NSMethodSignature *)methodSignatureForSelector:(SEL)aSelector
 {
-	return [batchTarget methodSignatureForSelector:aSelector];
+	if([batchTarget count])
+	{
+		id firstObject = [batchTarget objectAtIndex:0];
+		NSMethodSignature *sig =  [firstObject methodSignatureForSelector:aSelector];
+		return sig;
+	}
+
+	return nil;
 }
 
 @end

ActorKit/NSInvocation+Copy.m

@@ -16,16 +16,17 @@ - (id)copy
 	NSInvocation *copy = [NSInvocation invocationWithMethodSignature:[self methodSignature]];
 	[copy setTarget:[self target]];
 	[copy setSelector:[self selector]];
+
 	char buffer[sizeof(intmax_t)]; 
 
 	NSUInteger argCount = [[self methodSignature] numberOfArguments];
 
-	for (int i = 0; i < argCount; i++)
+	for (int i = 2; i < argCount; i++)
 	{
 		[self getArgument:(void *)&buffer atIndex:i];
 		[copy setArgument:(void *)&buffer atIndex:i];
 	}
-
+		
 	return copy;
 }
 

README.txt

@@ -92,6 +92,8 @@ Notes
 
 To Do
 
+	- handle BatchProxy exceptions
+
 	- extend collection classes to use workqueues for makeObjectsPerform: etc
 
 	- future notifications of some kind