Draft 16 support

lib/common/tsconfig.json

@@ -3,7 +3,5 @@
 	"compilerOptions": {
 		"composite": true
 	},
-	"include": [
-		"."
-	]
-}
+	"include": ["."]
+}

lib/contribute/broadcast.ts

@@ -46,13 +46,13 @@
 			const settings = media.getSettings()
 
 			if (media.kind === "audio") {
-				const audioContext = new AudioContext();
+				const audioContext = new AudioContext()
 				audioContext.createMediaStreamSource(new MediaStream([media]))
 				const sampleRate = audioContext.sampleRate
 				Object.assign(settings, {
 					sampleRate,
 				})
 				audioContext.close()
 			}
 
 			console.log("track settings", settings, media, mediaTracks)
@@ -121,7 +121,7 @@
 		console.log("[Broadcast] #run loop started")
 		await this.connection.publish_namespace(this.namespace)
 
-		for (; ;) {
+		for (;;) {
 			const subscriber = await this.connection.subscribed()
 			if (!subscriber) break
 
@@ -164,7 +164,7 @@
 		const bytes = Catalog.encode(this.catalog)
 
 		await subscriber.ack()
-		await sleep(500);
+		await sleep(500)
 
 		const stream = await subscriber.subgroup({ group: 0, subgroup: 0 })
 		await stream.write({ object_id: 0, object_payload: bytes })
@@ -176,7 +176,7 @@
 		if (!track) throw new Error(`no track with name ${subscriber.track}`)
 
 		await subscriber.ack()
-		await sleep(500);
+		await sleep(500)
 
 		const init = await track.init()
 
@@ -193,11 +193,11 @@
 		await subscriber.ack()
 
 		// NOTE(itzmanish): hack to make sure subscribe ok reaches before the segement object
-		await sleep(500);
+		await sleep(500)
 
 		const segments = track.segments().getReader()
 
-		for (; ;) {
+		for (;;) {
 			const { value: segment, done } = await segments.read()
 			if (done) break
 
@@ -221,7 +221,7 @@
 
 		// Pipe the segment to the stream.
 		const chunks = segment.chunks().getReader()
-		for (; ;) {
+		for (;;) {
 			const { value, done } = await chunks.read()
 			if (done) break
 

lib/contribute/container.ts

@@ -125,7 +125,7 @@ export class Container {
 
 		// Moof and mdat atoms are written in pairs.
 		// TODO remove the moof/mdat from the Box to reclaim memory once everything works
-		for (; ;) {
+		for (;;) {
 			const moof = this.#mp4.moofs.shift()
 			const mdat = this.#mp4.mdats.shift()
 

lib/contribute/track.ts

@@ -141,7 +141,7 @@ export class Track {
 
 		return new ReadableStream({
 			pull: async (controller) => {
-				for (; ;) {
+				for (;;) {
 					let index = pos - this.#offset
 					if (index < 0) index = 0
 

lib/contribute/tsconfig.json

@@ -1,13 +1,8 @@
 {
 	"extends": "../tsconfig.json",
-	"include": [
-		"."
-	],
+	"include": ["."],
 	"compilerOptions": {
-		"types": [
-			"dom-mediacapture-transform",
-			"dom-webcodecs"
-		]
+		"types": ["dom-mediacapture-transform", "dom-webcodecs"]
 	},
 	"references": [
 		{
@@ -20,4 +15,4 @@
 			"path": "../media"
 		}
 	]
-}
+}

lib/media/tsconfig.json

@@ -1,12 +1,8 @@
 {
 	"extends": "../tsconfig.json",
-	"include": [
-		"."
-	],
+	"include": ["."],
 	"compilerOptions": {
-		"types": [
-			"mp4box"
-		]
+		"types": ["mp4box"]
 	},
 	"references": [
 		{
@@ -16,4 +12,4 @@
 			"path": "../common"
 		}
 	]
-}
+}

lib/moq-publisher/index.ts

@@ -57,7 +57,7 @@
 		this.handleClick = this.handleClick.bind(this)
 
 		// Listeners
 		navigator.mediaDevices.addEventListener("devicechange", this.handleDeviceChange)
 		this.cameraSelect.addEventListener("change", () => this.startPreview())
 		this.microphoneSelect.addEventListener("change", () => this.startPreview())
 		this.connectButton.addEventListener("click", this.handleClick)
@@ -194,4 +194,4 @@
 }
 
 customElements.define("publisher-moq", PublisherMoq)
-export default PublisherMoq
+export default PublisherMoq

lib/package.json

@@ -83,4 +83,4 @@
 		"type": "git",
 		"url": "https://github.com/englishm/moq-js"
 	}
-}
+}

lib/playback/index.ts

@@ -154,7 +154,7 @@ export default class Player extends EventTarget {
 
 		try {
 			console.log("starting segment data loop")
-			for (; ;) {
+			for (;;) {
 				console.log("waiting for segment data")
 				const segment = await Promise.race([sub.data(), this.#running])
 				if (!segment) continue

lib/playback/worker/index.ts

@@ -87,7 +87,7 @@ class Worker {
 		segments.releaseLock()
 
 		// Read each chunk, decoding the MP4 frames and adding them to the queue.
-		for (; ;) {
+		for (;;) {
 			const chunk = await reader.read()
 			if (!chunk) {
 				break

lib/playback/worker/video.ts

@@ -57,7 +57,7 @@ export class Renderer {
 
 	async #run() {
 		const reader = this.#timeline.frames.pipeThrough(this.#queue).getReader()
-		for (; ;) {
+		for (;;) {
 			const { value: frame, done } = await reader.read()
 			if (this.#paused) continue
 			if (done) break

lib/publish/index.ts

@@ -51,4 +51,4 @@ export class PublisherApi {
 			await this.connection.closed()
 		}
 	}
-}
+}