We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent af7062e commit af5f02cCopy full SHA for af5f02c
webrtc.go
@@ -102,8 +102,16 @@ func newSession(config SessionConfig) (*Session, error) {
102
switch d.Label() {
103
case "rpc":
104
session.RPCChannel = d
105
+ fmt.Println("starting rpc server")
106
rpcServer := NewDataChannelJsonRpcServer(d)
107
+ d.OnError(func(err error) {
108
+ fmt.Println("rpc error", err)
109
+ })
110
+ d.OnClose(func() {
111
+ fmt.Println("rpc closed")
112
113
d.OnMessage(func(msg webrtc.DataChannelMessage) {
114
+ fmt.Println("rpc msg")
115
rpcServer.HandleMessage(msg.Data)
116
})
117
triggerOTAStateUpdate()
0 commit comments