mirror of
https://github.com/go-micro/go-micro.git
synced 2025-01-05 10:20:53 +02:00
Merge branch 'master' of ssh://github.com/asim/go-micro
This commit is contained in:
commit
a8224e1c67
@ -75,6 +75,7 @@ See the [examples](https://github.com/go-micro/examples) for detailed informatio
|
|||||||
|
|
||||||
See [github.com/go-micro](https://github.com/go-micro) for tooling.
|
See [github.com/go-micro](https://github.com/go-micro) for tooling.
|
||||||
|
|
||||||
|
- [API](https://github.com/go-micro/api)
|
||||||
- [CLI](https://github.com/go-micro/cli)
|
- [CLI](https://github.com/go-micro/cli)
|
||||||
- [Demo](https://github.com/go-micro/demo)
|
- [Demo](https://github.com/go-micro/demo)
|
||||||
- [Plugins](https://github.com/go-micro/plugins)
|
- [Plugins](https://github.com/go-micro/plugins)
|
||||||
|
@ -153,12 +153,11 @@ func (h *httpTransportClient) Recv(m *Message) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
h.Lock()
|
h.Lock()
|
||||||
|
defer h.Unlock()
|
||||||
if h.closed {
|
if h.closed {
|
||||||
h.Unlock()
|
|
||||||
return io.EOF
|
return io.EOF
|
||||||
}
|
}
|
||||||
rsp, err := http.ReadResponse(h.buff, r)
|
rsp, err := http.ReadResponse(h.buff, r)
|
||||||
h.Unlock()
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user