Commit6d33c42

committed

feat(connect): implement junction

1 parent4902598 commit6d33c42Copy full SHA for 6d33c42

File tree

+47

-3

lines changed

+47

-3

lines changed

Lines changed: 20 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,23 @@`
`1`	`1`	`"use strict";`
`2`		`-functionapplyMiddleware(text,middleware,next){`
`3`		`-middleware(text,next);`
	`2`	`+functionisErrorHandingMiddleware(middleware){`
	`3`	`+// middleware(error, text, next)`
	`4`	`+vararity=middleware.length;`
	`5`	`+returnarity===3;`
	`6`	`+}`
	`7`	`+functionapplyMiddleware(error,text,middleware,next){`
	`8`	`+leterrorOnMiddleware=null;`
	`9`	`+try{`
	`10`	`+if(error&&isErrorHandingMiddleware(middleware)){`
	`11`	`+middleware(error,text,next);`
	`12`	`+}else{`
	`13`	`+middleware(text,next);`
	`14`	`+}`
	`15`	`+return;`
	`16`	`+}catch(error){`
	`17`	`+errorOnMiddleware=error;`
	`18`	`+}`
	`19`	`+// skip the middleware or Error on the middleware`
	`20`	`+next(errorOnMiddleware,text);`
`4`	`21`	`}`
`5`	`22`
`6`	`23`	`exportdefaultclassJunction{`
`@@ -18,7 +35,7 @@ export default class Junction {`
`18`	`35`	`if(!middleware){`
`19`	`36`	`returncallback(error,data);`
`20`	`37`	`}`
`21`		`-applyMiddleware(data,middleware,next);`
	`38`	`+applyMiddleware(error,data,middleware,next);`
`22`	`39`	`};`
`23`	`40`	`next(null,text);`
`24`	`41`	`}`

Lines changed: 27 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,27 @@`
	`1`	`+// LICENSE : MIT`
	`2`	`+"use strict";`
	`3`	`+importassertfrom"power-assert";`
	`4`	`+importJunctionfrom"../../src/connect/junction";`
	`5`	`+describe("junction",function(){`
	`6`	`+describe("when",function(){`
	`7`	`+it("should",function(done){`
	`8`	`+varjunction=newJunction();`
	`9`	`+junction.use(functionerrorHandling(error,text,next){`
	`10`	`+next(error);`
	`11`	`+});`
	`12`	`+junction.use(functiontoUpper(text,next){`
	`13`	`+next(null,text.toLocaleUpperCase());`
	`14`	`+});`
	`15`	`+junction.use(functionaddDesu(text,next){`
	`16`	`+next(null,text+" suffix");`
	`17`	`+});`
	`18`	`+junction.process("text",(error,result)=>{`
	`19`	`+if(error){`
	`20`	`+returndone(error);`
	`21`	`+}`
	`22`	`+assert.equal(result,"TEXT suffix");`
	`23`	`+done();`
	`24`	`+});`
	`25`	`+});`
	`26`	`+});`
	`27`	`+});`

Comments

(0)