mirror of
https://github.com/pion/mediadevices.git
synced 2025-09-26 20:41:46 +08:00
33 lines
655 B
Go
33 lines
655 B
Go
package mediadevices
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/pion/webrtc/v2"
|
|
"github.com/pion/webrtc/v2/pkg/media"
|
|
)
|
|
|
|
type sampler struct {
|
|
track *webrtc.Track
|
|
clockRate float64
|
|
lastTimestamp time.Time
|
|
}
|
|
|
|
func newSampler(track *webrtc.Track) *sampler {
|
|
return &sampler{
|
|
track: track,
|
|
clockRate: float64(track.Codec().ClockRate),
|
|
lastTimestamp: time.Now(),
|
|
}
|
|
}
|
|
|
|
func (s *sampler) sample(b []byte) error {
|
|
now := time.Now()
|
|
duration := now.Sub(s.lastTimestamp).Seconds()
|
|
samples := uint32(s.clockRate * duration)
|
|
s.lastTimestamp = now
|
|
|
|
sample := media.Sample{Data: b, Samples: samples}
|
|
return s.track.WriteSample(sample)
|
|
}
|