diff --git a/stream/mts/encoder.go b/stream/mts/encoder.go
index 8a4121a4..02761b91 100644
--- a/stream/mts/encoder.go
+++ b/stream/mts/encoder.go
@@ -201,7 +201,6 @@ type Encoder struct {
 
 	continuity map[int]byte
 
-	now         time.Time
 	psiLastTime time.Time
 }
 
@@ -234,13 +233,13 @@ const (
 // generate handles the incoming data and generates equivalent mpegts packets -
 // sending them to the output channel.
 func (e *Encoder) Encode(nalu []byte) error {
-	e.now = time.Now()
-	if e.now.Sub(e.psiLastTime) > psiInterval {
+	now := time.Now()
+	if now.Sub(e.psiLastTime) > psiInterval {
 		err := e.writePSI()
 		if err != nil {
 			return err
 		}
-		e.psiLastTime = e.now
+		e.psiLastTime = now
 	}
 
 	// Prepare PES data.