diff --git a/lib/broadcast-operator.ts b/lib/broadcast-operator.ts index 255f52ded7..48e295cb78 100644 --- a/lib/broadcast-operator.ts +++ b/lib/broadcast-operator.ts @@ -254,7 +254,7 @@ export class BroadcastOperator clearTimeout(timer); ack.apply(this, [ null, - this.flags.expectSingleResponse ? null : responses, + this.flags.expectSingleResponse ? responses[0] : responses, ]); } };