Live video on the AT Protocol
stream.place
rtcrec: rename files
-4
pkg/rtcrec/peerproxy.go
pkg/rtcrec/rtcrec.go
-4
pkg/rtcrec/peerproxy.go
pkg/rtcrec/rtcrec.go
···
37
37
}
38
38
39
39
func GatheringCompletePromise(pc PeerConnection) <-chan struct{} {
40
-
wrapped, ok := pc.(*WrappedPeerConnection)
41
-
if ok {
42
-
return webrtc.GatheringCompletePromise(wrapped.pionpc)
43
-
}
44
40
recorder, ok := pc.(*RecorderPeerConnection)
45
41
if ok {
46
42
return webrtc.GatheringCompletePromise(recorder.pionpc)
pkg/rtcrec/recorder.go
pkg/rtcrec/wrapped_peerconnection.go
pkg/rtcrec/recorder.go
pkg/rtcrec/wrapped_peerconnection.go
-78
pkg/rtcrec/wrapped.go
-78
pkg/rtcrec/wrapped.go
···
1
-
package rtcrec
2
-
3
-
import (
4
-
"github.com/pion/rtcp"
5
-
"github.com/pion/webrtc/v4"
6
-
)
7
-
8
-
type WrappedPeerConnection struct {
9
-
pionpc *webrtc.PeerConnection
10
-
}
11
-
12
-
func NewWrappedPC(pionpc *webrtc.PeerConnection) PeerConnection {
13
-
return &WrappedPeerConnection{
14
-
pionpc: pionpc,
15
-
}
16
-
}
17
-
18
-
func (pc *WrappedPeerConnection) Close() error {
19
-
return pc.pionpc.Close()
20
-
}
21
-
22
-
func (pc *WrappedPeerConnection) CreateAnswer(options *webrtc.AnswerOptions) (webrtc.SessionDescription, error) {
23
-
return pc.pionpc.CreateAnswer(options)
24
-
}
25
-
26
-
func (pc *WrappedPeerConnection) CreateOffer(options *webrtc.OfferOptions) (webrtc.SessionDescription, error) {
27
-
return pc.pionpc.CreateOffer(options)
28
-
}
29
-
30
-
func (pc *WrappedPeerConnection) SetLocalDescription(desc webrtc.SessionDescription) error {
31
-
return pc.pionpc.SetLocalDescription(desc)
32
-
}
33
-
34
-
func (pc *WrappedPeerConnection) SetRemoteDescription(desc webrtc.SessionDescription) error {
35
-
return pc.pionpc.SetRemoteDescription(desc)
36
-
}
37
-
38
-
func (pc *WrappedPeerConnection) LocalDescription() *webrtc.SessionDescription {
39
-
return pc.pionpc.LocalDescription()
40
-
}
41
-
42
-
func (pc *WrappedPeerConnection) RemoteDescription() *webrtc.SessionDescription {
43
-
return pc.pionpc.RemoteDescription()
44
-
}
45
-
46
-
func (pc *WrappedPeerConnection) OnICEConnectionStateChange(f func(webrtc.ICEConnectionState)) {
47
-
pc.pionpc.OnICEConnectionStateChange(f)
48
-
}
49
-
50
-
func (pc *WrappedPeerConnection) OnConnectionStateChange(f func(webrtc.PeerConnectionState)) {
51
-
pc.pionpc.OnConnectionStateChange(f)
52
-
}
53
-
54
-
func (pc *WrappedPeerConnection) OnTrack(f func(TrackRemote, RTPReceiver)) {
55
-
pc.pionpc.OnTrack(func(track *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {
56
-
f(track, receiver)
57
-
})
58
-
}
59
-
60
-
func (pc *WrappedPeerConnection) WriteRTCP(pkts []rtcp.Packet) error {
61
-
return pc.pionpc.WriteRTCP(pkts)
62
-
}
63
-
64
-
func (pc *WrappedPeerConnection) AddTransceiverFromKind(kind webrtc.RTPCodecType, init ...webrtc.RTPTransceiverInit) (RTPTransceiver, error) {
65
-
return pc.pionpc.AddTransceiverFromKind(kind, init...)
66
-
}
67
-
68
-
func (pc *WrappedPeerConnection) ICEGatheringState() webrtc.ICEGatheringState {
69
-
return pc.pionpc.ICEGatheringState()
70
-
}
71
-
72
-
func (pc *WrappedPeerConnection) OnDataChannel(f func(*webrtc.DataChannel)) {
73
-
pc.pionpc.OnDataChannel(f)
74
-
}
75
-
76
-
func (pc *WrappedPeerConnection) OnNegotiationNeeded(f func()) {
77
-
pc.pionpc.OnNegotiationNeeded(f)
78
-
}