package/mediadevices
1
0
Fork 0
mirror of https://github.com/pion/mediadevices.git synced 2026-04-23 00:07:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update from io.ReadCloser to codec.ReadCloser

Browse Source
This commit is contained in:
Lukas Herman
2020-03-25 20:50:26 -04:00
committed by Lukas Herman
parent e9ad427815
commit 354f2710b5
14 changed files with 99 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/codec/vpx/vpx.go
+12 -4
View File
@@ -55,10 +55,10 @@ import (
"time"
"unsafe"
"github.com/pion/mediadevices/pkg/codec"
mio "github.com/pion/mediadevices/pkg/io"
"github.com/pion/mediadevices/pkg/io/video"
"github.com/pion/mediadevices/pkg/prop"
"github.com/pion/webrtc/v2"
)
@@ -100,7 +100,7 @@ func (p *VP8Params) Name() string {
}
// BuildVideoEncoder builds VP8 encoder with given params
func (p *VP8Params) BuildVideoEncoder(r video.Reader, property prop.Media) (io.ReadCloser, error) {
func (p *VP8Params) BuildVideoEncoder(r video.Reader, property prop.Media) (codec.ReadCloser, error) {
return newEncoder(r, property, p.Params, C.ifaceVP8())
}
@@ -127,7 +127,7 @@ func (p *VP9Params) Name() string {
}
// BuildVideoEncoder builds VP9 encoder with given params
func (p *VP9Params) BuildVideoEncoder(r video.Reader, property prop.Media) (io.ReadCloser, error) {
func (p *VP9Params) BuildVideoEncoder(r video.Reader, property prop.Media) (codec.ReadCloser, error) {
return newEncoder(r, property, p.Params, C.ifaceVP9())
}
@@ -145,7 +145,7 @@ func newParams(codecIface *C.vpx_codec_iface_t) (Params, error) {
}, nil
}
func newEncoder(r video.Reader, p prop.Media, params Params, codecIface *C.vpx_codec_iface_t) (io.ReadCloser, error) {
func newEncoder(r video.Reader, p prop.Media, params Params, codecIface *C.vpx_codec_iface_t) (codec.ReadCloser, error) {
if params.BitRate == 0 {
params.BitRate = 100000
}
@@ -273,6 +273,14 @@ func (e *encoder) Read(p []byte) (int, error) {
return n, err
}
func (e *encoder) SetBitRate(b int) error {
panic("SetBitRate is not implemented")
}
func (e *encoder) ForceKeyFrame() error {
panic("ForceKeyFrame is not implemented")
}
func (e *encoder) Close() error {
e.mu.Lock()
defer e.mu.Unlock()