@@ -101,6 +101,8 @@ describe('websocket Node', function() {
101101 helper . load ( websocketNode , flow , function ( ) {
102102 createClient ( "n1" ) . then ( function ( sock ) {
103103 done ( ) ;
104+ } ) . catch ( function ( err ) {
105+ done ( err ) ;
104106 } ) ;
105107 } ) ;
106108 } ) ;
@@ -113,6 +115,8 @@ describe('websocket Node', function() {
113115 done ( ) ;
114116 } ) ;
115117 helper . clearFlows ( ) ;
118+ } ) . catch ( function ( err ) {
119+ done ( err ) ;
116120 } ) ;
117121 } ) ;
118122 } ) ;
@@ -129,6 +133,8 @@ describe('websocket Node', function() {
129133 done ( ) ;
130134 } ) ;
131135 sock . send ( "hello" ) ;
136+ } ) . catch ( function ( err ) {
137+ done ( err ) ;
132138 } ) ;
133139 } ) ;
134140 } ) ;
@@ -145,6 +151,8 @@ describe('websocket Node', function() {
145151 msg . should . have . property ( "text" , "hello" ) ;
146152 done ( ) ;
147153 } ) ;
154+ } ) . catch ( function ( err ) {
155+ done ( err ) ;
148156 } ) ;
149157 } ) ;
150158 } ) ;
@@ -161,6 +169,8 @@ describe('websocket Node', function() {
161169 msg . should . have . property ( "payload" , "hello" ) ;
162170 done ( ) ;
163171 } ) ;
172+ } ) . catch ( function ( err ) {
173+ done ( err ) ;
164174 } ) ;
165175 } ) ;
166176 } ) ;
@@ -179,6 +189,8 @@ describe('websocket Node', function() {
179189 helper . getNode ( "n2" ) . send ( {
180190 payload : "hello"
181191 } ) ;
192+ } ) . catch ( function ( err ) {
193+ done ( err ) ;
182194 } ) ;
183195 } ) ;
184196 } ) ;
@@ -197,6 +209,8 @@ describe('websocket Node', function() {
197209 helper . getNode ( "n3" ) . send ( {
198210 text : "hello"
199211 } ) ;
212+ } ) . catch ( function ( err ) {
213+ done ( err ) ;
200214 } ) ;
201215 } ) ;
202216 } ) ;
@@ -216,6 +230,8 @@ describe('websocket Node', function() {
216230 done ( ) ;
217231 } , 100 ) ;
218232 helper . getNode ( "n2" ) . send ( { topic : "hello" } ) ;
233+ } ) . catch ( function ( err ) {
234+ done ( err ) ;
219235 } ) ;
220236 } ) ;
221237 } ) ;
@@ -232,6 +248,8 @@ describe('websocket Node', function() {
232248 done ( ) ;
233249 } ) ;
234250 sock . send ( "hello" ) ;
251+ } ) . catch ( function ( err ) {
252+ done ( err ) ;
235253 } ) ;
236254 } ) ;
237255 } ) ;
@@ -248,6 +266,8 @@ describe('websocket Node', function() {
248266 done ( ) ;
249267 } ) ;
250268 sock . send ( '{"text":"hello"}' ) ;
269+ } ) . catch ( function ( err ) {
270+ done ( err ) ;
251271 } ) ;
252272 } ) ;
253273 } ) ;
@@ -272,10 +292,11 @@ describe('websocket Node', function() {
272292 helper . getNode ( "n3" ) . send ( {
273293 payload : "hello"
274294 } ) ;
275- } ) ;
276-
277- when . all ( [ def1 . promise , def2 . promise ] ) . then ( function ( ) {
278- done ( ) ;
295+ return when . all ( [ def1 . promise , def2 . promise ] ) . then ( function ( ) {
296+ done ( ) ;
297+ } ) ;
298+ } ) . catch ( function ( err ) {
299+ done ( err ) ;
279300 } ) ;
280301 } ) ;
281302 } ) ;
0 commit comments