parent
0a030f3d8a
commit
7253635cd3
@ -67,23 +67,9 @@ func (s *Socket) Local() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *Socket) Send(m *transport.Message) error {
|
func (s *Socket) Send(m *transport.Message) error {
|
||||||
// make copy
|
|
||||||
msg := &transport.Message{
|
|
||||||
Header: make(map[string]string),
|
|
||||||
Body: make([]byte, len(m.Body)),
|
|
||||||
}
|
|
||||||
|
|
||||||
// copy headers
|
|
||||||
for k, v := range m.Header {
|
|
||||||
msg.Header[k] = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// copy body
|
|
||||||
copy(msg.Body, m.Body)
|
|
||||||
|
|
||||||
// send a message
|
// send a message
|
||||||
select {
|
select {
|
||||||
case s.send <- msg:
|
case s.send <- m:
|
||||||
case <-s.closed:
|
case <-s.closed:
|
||||||
return io.EOF
|
return io.EOF
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user