return proper error in drain

This commit is contained in:
Darien Raymond
2017-10-21 19:27:20 +02:00
parent 103cb48692
commit badc77a7f7
+1 -2
View File
@@ -187,8 +187,7 @@ func (m *Client) Dispatch(ctx context.Context, outboundRay ray.OutboundRay) bool
}
func drain(reader io.Reader) error {
buf.Copy(NewStreamReader(reader), buf.Discard)
return nil
return buf.Copy(NewStreamReader(reader), buf.Discard)
}
func (m *Client) handleStatueKeepAlive(meta *FrameMetadata, reader io.Reader) error {