File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -312,7 +312,11 @@ Incoming.prototype.on_transfer = function(frame, receiver) {
312312 if ( util . is_defined ( frame . performative . delivery_id ) && current . id !== frame . performative . delivery_id ) {
313313 throw Error ( 'frame sequence error: delivery ' + current . id + ' not complete, got ' + frame . performative . delivery_id ) ;
314314 }
315- data = Buffer . concat ( [ current . data , frame . payload ] , current . data . length + frame . payload . length ) ;
315+ if ( frame . payload ) {
316+ data = Buffer . concat ( [ current . data , frame . payload ] , current . data . length + frame . payload . length ) ;
317+ } else {
318+ data = current . data ;
319+ }
316320 } else if ( this . next_delivery_id === frame . performative . delivery_id ) {
317321 current = { 'id' :frame . performative . delivery_id ,
318322 'tag' :frame . performative . delivery_tag ,
You can’t perform that action at this time.
0 commit comments