commons_go/rpc
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2017-11-23 18:22:27 +09:00
parent 99e3263594
commit 1248d128a1
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
notify/notify.go
View File

@ -143,7 +143,7 @@ func (n *notify) rpcWriter(stopChan <-chan struct{}, writerDone chan<- error) {
continue continue
} }
err = n.nh.GetCodec().Write(n.conn, cs.Method, cs.Args, cs.ID) err = n.nh.GetCodec().Write(n.conn, cs.Method, cs.Args, nil)
cs.Error = err cs.Error = err
cs.Done() cs.Done()
if nil != err { if nil != err {