diff --git a/lib/contribute/broadcast.ts b/lib/contribute/broadcast.ts index 2f8224f..32d79a4 100644 --- a/lib/contribute/broadcast.ts +++ b/lib/contribute/broadcast.ts @@ -149,7 +149,7 @@ export class Broadcast { await subscriber.ack() const stream = await subscriber.group({ group: 0 }) - await stream.write({ object: 0, payload: bytes }) + await stream.write({ object: 0, status: 0, payload: bytes }) await stream.close() } @@ -163,7 +163,7 @@ export class Broadcast { const init = await track.init() const stream = await subscriber.group({ group: 0 }) - await stream.write({ object: 0, payload: init }) + await stream.write({ object: 0, status: 0, payload: init }) await stream.close() } @@ -205,6 +205,7 @@ export class Broadcast { await stream.write({ object, + status: 0, payload: value, }) diff --git a/lib/transport/publisher.ts b/lib/transport/publisher.ts index eeaa9c7..547344d 100644 --- a/lib/transport/publisher.ts +++ b/lib/transport/publisher.ts @@ -224,6 +224,7 @@ export class SubscribeRecv { group: props.group, object: props.object, priority: props.priority ?? 0, + status: 0, }) } }