Merge pull request #172 from foxdonut/fan-out

Allow connecting to multiple methods using an array.
cujojs · Apr 27, 2015 · 0857ac6 · 0857ac6
2 parents 469cf83 + fe79d2b
commit 0857ac6
Show file tree

Hide file tree

Showing 3 changed files with 373 additions and 16 deletions.
diff --git a/docs/connections.md b/docs/connections.md
@@ -267,6 +267,34 @@ define({
 });
 ```
 
+Connections can also be made to more than one method. Use an array of Strings instead of a single String to invoke multiple methods:
+
+```js
+define({
+	$plugins: [
+		{ module: 'wire/connect'},
+		// other plugins ...
+	],
+
+	component1: {
+		create: // ...
+		connect: {
+			// Whenever component2.doSomething is called,
+			// component1.doSomethingAlso1 and component1.doSomethingAlso2 will also
+			// be invoked, with the same parameters.
+			'component2.doSomething': [
+				'doSomethingAlso1',
+				'doSomethingAlso2'
+			]
+		}
+	},
+
+	component2: {
+		create: // ...
+	}
+});
+```
+
 # Aspect Oriented Programming (AOP)
 
 **Plugin:** wire/aop
@@ -304,7 +332,16 @@ define({
 	        // component2.doSomething returns (but not if it throws, see
 	        // afterThrowing below).  The return value of component2.doSomething
 	        // will be passed to component1.doSomethingAfterReturning
-	        doSomething: 'component1.doSomethingAfterReturning'
+	        doSomething: 'component1.doSomethingAfterReturning',
+
+	        // component1.doSomething1 and component1.doSomething2 will be
+	        // invoked after component2.doSomethingElse returns.  The return
+	        // value of component2.doSomething will be passed to both
+	        // component1.doSomething1 and component1.doSomething2.
+	        doSomethingElse: [
+	          'component1.doSomething1',
+	          'component1.doSomething2'
+	        ]
 	    },
 
 	    afterThrowing: {

diff --git a/lib/connection.js b/lib/connection.js
@@ -104,29 +104,30 @@ define(function(require) {
 	 *  rejects if an error occurs.
 	 */
 	function parseIncoming(source, eventName, targetProxy, connect, options, wire, createConnection) {
-		var promise, methodName;
+		var promise, methodNames;
 
 		if(eventName) {
 			// 'component.eventName': 'methodName'
 			// 'component.eventName': 'transform | methodName'
 
-			methodName = options;
+			methodNames = Array.isArray(options) ? options : [ options ];
 
-			promise = pipeline(targetProxy, methodName, wire).then(
-				function(func) {
-					var invoker = proxyInvoker(targetProxy, func);
+			promise = when.map(methodNames, function(methodName) {
+				return pipeline(targetProxy, methodName, wire).then(
+					function(func) {
+						var invoker = proxyInvoker(targetProxy, func);
 
-					return createConnection(source, eventName, invoker);
-				}
-			);
+						return createConnection(source, eventName, invoker);
+					}
+				);
+			});
 
 		} else {
 			// componentName: {
 			//   eventName: 'methodName'
 			//   eventName: 'transform | methodName'
 			// }
 
-			source = methodName;
 			promise = wire.getProxy(connect).then(function(srcProxy) {
 				var name, promises;
 
@@ -190,10 +191,6 @@ define(function(require) {
 			promise = connectOneOutgoing(targetProxy, options);
 
 		} else {
-			// eventName: {
-			//   componentName: 'methodName'
-			//   componentName: 'transform | methodName'
-			// }
 			promises = [];
 
 			resolveAndConnectOneOutgoing = function(targetRef, targetMethodSpec) {
@@ -202,8 +199,20 @@ define(function(require) {
 				});
 			};
 
-			for(name in options) {
-				promises.push(resolveAndConnectOneOutgoing(name, options[name]));
+			if (Array.isArray(options)) {
+				// eventName: [ 'methodName1', 'methodName2' ]
+				for (var i = 0, t = options.length; i < t; i++) {
+					promises.push(connectOneOutgoing(targetProxy, options[i]));
+				}
+
+			} else {
+				// eventName: {
+				//   componentName: 'methodName'
+				//   componentName: 'transform | methodName'
+				// }
+				for(name in options) {
+					promises.push(resolveAndConnectOneOutgoing(name, options[name]));
+				}
 			}
 
 			promise = when.all(promises);