zishuo/webrtc
1
0
Fork 0
mirror of https://github.com/pion/webrtc.git synced 2025-10-30 02:12:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

API: Review DataChannel

Browse Source 
Resolves #427
This commit is contained in:
backkem
2019-02-21 10:36:59 +01:00
committed by Michiel De Backker
parent bfba81167e
commit f5d11df18d
10 changed files with 99 additions and 218 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
examples/ortc/main.go
View File

@@ -6,7 +6,6 @@ import (
"time"
"github.com/pions/webrtc"
sugar "github.com/pions/webrtc/pkg/datachannel"
"github.com/pions/webrtc/examples/internal/signal"
)
@@ -51,7 +50,9 @@ func main() {
// Register the handlers
channel.OnOpen(handleOnOpen(channel))
channel.OnMessage(handleMessage(channel))
channel.OnMessage(func(msg webrtc.DataChannelMessage) {
fmt.Printf("Message from DataChannel '%s': '%s'\n", channel.Label, string(msg.Data))
})
})
// Gather candidates
@@ -129,7 +130,9 @@ func main() {
// Register the handlers
// channel.OnOpen(handleOnOpen(channel)) // TODO: OnOpen on handle ChannelAck
go handleOnOpen(channel)() // Temporary alternative
channel.OnMessage(handleMessage(channel))
channel.OnMessage(func(msg webrtc.DataChannelMessage) {
fmt.Printf("Message from DataChannel '%s': '%s'\n", channel.Label, string(msg.Data))
})
}
select {}
@@ -151,25 +154,12 @@ func handleOnOpen(channel *webrtc.DataChannel) func() {
for range time.NewTicker(5 * time.Second).C {
message := signal.RandSeq(15)
fmt.Printf("Sending %s \n", message)
fmt.Printf("Sending '%s' \n", message)
err := channel.Send(sugar.PayloadString{Data: []byte(message)})
err := channel.SendText(message)
if err != nil {
panic(err)
}
}
}
}
func handleMessage(channel *webrtc.DataChannel) func(sugar.Payload) {
return func(payload sugar.Payload) {
switch p := payload.(type) {
case *sugar.PayloadString:
fmt.Printf("Message '%s' from DataChannel '%s' payload '%s'\n", p.PayloadType().String(), channel.Label, string(p.Data))
case *sugar.PayloadBinary:
fmt.Printf("Message '%s' from DataChannel '%s' payload '% 02x'\n", p.PayloadType().String(), channel.Label, p.Data)
default:
fmt.Printf("Message '%s' from DataChannel '%s' no payload \n", p.PayloadType().String(), channel.Label)
}
}
}