tangled
alpha
login
or
join now
stream.place
/
streamplace
Live video on the AT Protocol
74
fork
atom
overview
issues
1
pulls
pipelines
chore: go fmt
dignifiedquire
6 months ago
d95cfce2
93db7cfc
+16
-16
1 changed file
expand all
collapse all
unified
split
pkg
iroh_streamplace
iroh_streamplace_test.go
+16
-16
pkg/iroh_streamplace/iroh_streamplace_test.go
···
16
16
handler.messages <- data
17
17
}
18
18
19
19
-
func TestBasicRoundtrip(t *testing.T) {
20
20
-
sender := iroh.NewSenderEndpoint()
19
19
+
func TestBasicRoundtrip(t *testing.T) {
20
20
+
sender := iroh.NewSenderEndpoint()
21
21
22
22
messages := make(chan []byte, 5)
23
23
-
handler := TestHandler { messages: messages }
23
23
+
handler := TestHandler{messages: messages}
24
24
25
25
-
receiver := iroh.NewReceiverEndpoint(&handler)
25
25
+
receiver := iroh.NewReceiverEndpoint(&handler)
26
26
27
27
-
receiverAddr := receiver.NodeAddr()
28
28
-
receiverId := receiverAddr.NodeId()
27
27
+
receiverAddr := receiver.NodeAddr()
28
28
+
receiverId := receiverAddr.NodeId()
29
29
30
30
-
// add peer
31
31
-
sender.AddPeer(receiverAddr)
30
30
+
// add peer
31
31
+
sender.AddPeer(receiverAddr)
32
32
33
33
-
// send a few messages
34
34
-
for i := range(5) {
35
35
-
sender.Send(receiverId, []byte{ byte(i), 0, 0, 0 })
36
36
-
}
33
33
+
// send a few messages
34
34
+
for i := range 5 {
35
35
+
sender.Send(receiverId, []byte{byte(i), 0, 0, 0})
36
36
+
}
37
37
38
38
-
// make sure the receiver got them
39
39
-
for i := range(5) {
40
40
-
msg := <- messages
41
41
-
assert.Equal(t, msg, []byte{byte(i), 0, 0, 0 })
38
38
+
// make sure the receiver got them
39
39
+
for i := range 5 {
40
40
+
msg := <-messages
41
41
+
assert.Equal(t, msg, []byte{byte(i), 0, 0, 0})
42
42
}
43
43
}