Skip to content

Commit 7f57492

Browse files
committed
fix(core): make frame pts and dts immutable
1 parent 16cd5fc commit 7f57492

File tree

2 files changed

+4
-4
lines changed
  • core/src/main/java/io/github/thibaultbee/streampack/core/elements/data
  • extensions/rtmp/src/main/java/io/github/thibaultbee/streampack/ext/rtmp/elements/endpoints

2 files changed

+4
-4
lines changed

core/src/main/java/io/github/thibaultbee/streampack/core/elements/data/Frame.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,12 +72,12 @@ data class Frame(
7272
/**
7373
* Presentation timestamp in µs
7474
*/
75-
var ptsInUs: Long,
75+
val ptsInUs: Long,
7676

7777
/**
7878
* Decoded timestamp in µs (not used).
7979
*/
80-
var dtsInUs: Long? = null,
80+
val dtsInUs: Long? = null,
8181

8282
/**
8383
* [Boolean.true] if frame is a key frame (I-frame for AVC/HEVC and audio frames)

extensions/rtmp/src/main/java/io/github/thibaultbee/streampack/ext/rtmp/elements/endpoints/RtmpEndpoint.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ class RtmpEndpoint internal constructor() : IEndpointInternal {
105105
rtmpClient.write(
106106
flvData,
107107
ts.toInt(),
108-
).await()
108+
)
109109
}
110110
if (flvData is AutoCloseable) {
111111
flvData.close()
@@ -147,7 +147,7 @@ class RtmpEndpoint internal constructor() : IEndpointInternal {
147147
rtmpClient.writeSetDataFrame(
148148
flvDataBuilder.metadata
149149
)
150-
}.await()
150+
}
151151
}
152152

153153
override suspend fun stopStream() {

0 commit comments

Comments
 (0)