Skip to content

Commit 7eb5380

Browse files
authored
Update websocket_test.go
add TestNewClient2
1 parent 45e6ad6 commit 7eb5380

File tree

1 file changed

+47
-0
lines changed

1 file changed

+47
-0
lines changed

websocket/websocket_test.go

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,53 @@ func newConfig(t *testing.T, path string) *Config {
136136
return config
137137
}
138138

139+
func doWriteRead(t *testing.T, conn *Conn) {
140+
var buf bytes.Buffer
141+
for i := 0; i < 5; i++ {
142+
n, err := conn.Write([]byte(fmt.Sprintf("websocket_test:%d", i)))
143+
if err != nil {
144+
t.Fatal("write:", err)
145+
return
146+
}
147+
for {
148+
var b [2]byte
149+
n, err = conn.Read(b[:])
150+
if n > 0 {
151+
buf.Write(b[:n])
152+
} else if err != nil {
153+
t.Fatal("err:", err)
154+
return
155+
}
156+
if buf.Len() == int(conn.FrameDataLength()) {
157+
t.Log("read:", string(buf.Bytes()))
158+
buf.Reset()
159+
break
160+
}
161+
}
162+
}
163+
}
164+
165+
func TestNewClient2(t *testing.T) {
166+
once.Do(startServer)
167+
168+
// websocket.Dial()
169+
client, err := net.Dial("tcp", serverAddr)
170+
if err != nil {
171+
t.Fatal("dialing", err)
172+
}
173+
conn, resp, err := NewClient2(newConfig(t, "/echo"), client)
174+
if err != nil {
175+
if resp != nil {
176+
t.Fatal("newClient2:StatusCode:", resp.StatusCode, " err:", err)
177+
} else {
178+
t.Fatal("newClient2:StatusCode:", 0, " err:", err)
179+
}
180+
return
181+
}
182+
183+
doWriteRead(t, conn)
184+
}
185+
139186
func TestEcho(t *testing.T) {
140187
once.Do(startServer)
141188

0 commit comments

Comments
 (0)