commons/server-go
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-04-13 18:50:14 +09:00
parent 57065b83df
commit e84aea5d11
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
socket/readwrite.go
View File

@ -4,6 +4,8 @@ import (
"fmt" "fmt"
"io" "io"
"time" "time"
logging "git.loafle.net/commons/logging-go"
) )
func connReadHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-chan struct{}, doneChan chan<- error, readChan chan<- []byte) { func connReadHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-chan struct{}, doneChan chan<- error, readChan chan<- []byte) {
@ -77,11 +79,13 @@ func connWriteHandler(readWriteHandler ReadWriteHandler, conn Conn, stopChan <-c
wc, err = conn.NextWriter(TextMessage) wc, err = conn.NextWriter(TextMessage)
if err != nil { if err != nil {
logging.Logger().Debug(err)
return return
} }
wc.Write(message) wc.Write(message)
if err = wc.Close(); nil != err { if err = wc.Close(); nil != err {
logging.Logger().Debug(err)
return return
} }
case <-ticker.C: case <-ticker.C: