commit
452dedf8ab
|
@ -118,7 +118,7 @@ type chanStream struct {
|
||||||
ctx context.Context
|
ctx context.Context
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *chanStream) Context() context.Context { return s.Context() }
|
func (s *chanStream) Context() context.Context { return s.ctx }
|
||||||
|
|
||||||
func (s *chanStream) SendMsg(m interface{}) error {
|
func (s *chanStream) SendMsg(m interface{}) error {
|
||||||
select {
|
select {
|
||||||
|
|
Loading…
Reference in New Issue