Update publish side to send object statuses

kixelated · Aug 9, 2024 · eb9e06b · eb9e06b
1 parent 97bf70f
commit eb9e06b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git 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
@@ -224,6 +224,7 @@ export class SubscribeRecv {
 			group: props.group,
 			object: props.object,
 			priority: props.priority ?? 0,
+			status: 0,
 		})
 	}
 }