Implements the streamer interface.
| 11 | |
| 12 | // Implements the streamer interface. |
| 13 | type grpcStream struct { |
| 14 | sync.RWMutex |
| 15 | closed bool |
| 16 | err error |
| 17 | stream grpc.ClientStream |
| 18 | request client.Request |
| 19 | response client.Response |
| 20 | context context.Context |
| 21 | cancel func() |
| 22 | release func(error) |
| 23 | } |
| 24 | |
| 25 | func (g *grpcStream) Context() context.Context { |
| 26 | return g.context |
nothing calls this directly
no outgoing calls
no test coverage detected