This repository was archived by the owner on Aug 30, 2024. It is now read-only.
File tree 1 file changed +12
-14
lines changed 1 file changed +12
-14
lines changed Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ package wsnet
3
3
import (
4
4
"context"
5
5
"errors"
6
- "fmt "
6
+ "io "
7
7
"testing"
8
8
9
9
"github.com/pion/webrtc/v3"
@@ -57,32 +57,30 @@ func TestDial(t *testing.T) {
57
57
if err != nil {
58
58
t .Error (err )
59
59
}
60
-
61
60
})
62
61
63
- t .Run ("Pipe " , func (t * testing.T ) {
62
+ t .Run ("Disconnect " , func (t * testing.T ) {
64
63
connectAddr , listenAddr := createDumbBroker (t )
65
64
listener , err := Listen (context .Background (), listenAddr )
66
65
if err != nil {
67
66
t .Error (err )
68
67
}
68
+ go func () {
69
+ c , _ := listener .Accept ()
70
+ c .Close ()
71
+ }()
69
72
dialer , err := Dial (context .Background (), connectAddr , nil )
70
73
if err != nil {
71
74
t .Error (err )
72
75
}
73
- go func () {
74
- conn , err := dialer .DialContext (context .Background (), "tcp" , "localhost:40000" )
75
- if err != nil {
76
- t .Error (err )
77
- }
78
- conn .Write ([]byte ("hello" ))
79
- }()
80
- conn , err := listener .Accept ()
76
+ conn , err := dialer .DialContext (context .Background (), "tcp" , "example" )
81
77
if err != nil {
82
78
t .Error (err )
83
79
}
84
- b := make ([]byte , 5 )
85
- _ , _ = conn .Read (b )
86
- fmt .Printf ("WE LEGIT GOT IT! %s\n " , b )
80
+ b := make ([]byte , 16 )
81
+ _ , err = conn .Read (b )
82
+ if err != io .EOF {
83
+ t .Error (err )
84
+ }
87
85
})
88
86
}
You can’t perform that action at this time.
0 commit comments