Merge branch 'master' of github.com:usepropeller/AFRocketClient

Author: clayallsopp

AFRocketClient/AFEventSource.m

@@ -212,12 +212,12 @@ - (BOOL)open:(NSError * __autoreleasing *)error {
     self.requestOperation.outputStream = self.outputStream;
 
     // TODO Determine correct retry behavior / customization
-//    [self.requestOperation setCompletionBlockWithSuccess:^(AFHTTPRequestOperation *operation, id responseObject) {
-//        NSLog(@"Success: %@", responseObject);
-//    } failure:^(AFHTTPRequestOperation *operation, NSError *error) {
-//        NSLog(@"Failure: %@", error);
-//    }];
-    
+    [self.requestOperation setCompletionBlockWithSuccess:^(AFHTTPRequestOperation *operation, id responseObject) {
+        NSLog(@"Success: %@", responseObject);
+    } failure:^(AFHTTPRequestOperation *operation, NSError *error) {
+        NSLog(@"Failure: %@", error);
+    }];
+
     [self.requestOperation start];
 
     self.state = AFEventSourceOpen;
@@ -299,11 +299,11 @@ - (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode {
                         [self.delegate eventSource:self didReceiveMessage:event];
                     }
 
-                    for (AFServerSentEventBlock block in [self.listenersKeyedByEvent objectForKey:event.event]) {
+                    [[self.listenersKeyedByEvent objectForKey:event.event] enumerateKeysAndObjectsUsingBlock:^(id key, AFServerSentEventBlock block, BOOL *stop) {
                         if (block) {
                             block(event);
                         }
-                    }
+                    }];
                 }
             }
             break;

AFRocketClient/AFRocketClient.m

@@ -62,8 +62,6 @@ - (AFEventSource *)openEventSourceWithRequest:(NSURLRequest *)request
         }
     }];
 
-    [eventSource open:error];
-
     return eventSource;
 }