google.golang.org/grpc/internal/transport.Stream.Context (method)
21 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L249: sh.HandleRPC(s.Context(), &stats.OutTrailer{
handler_server.go#L335: sh.HandleRPC(s.Context(), &stats.OutHeader{
http2_server.go#L1016: sh.HandleRPC(s.Context(), outHeader)
http2_server.go#L1082: sh.HandleRPC(s.Context(), &stats.OutTrailer{
transport.go#L413: func (s *Stream) Context() context.Context {
google.golang.org/grpc
rpc_util.go#L254: if x, ok := peer.FromContext(attempt.s.Context()); ok {
server.go#L1028: tr, ok := trace.FromContext(stream.Context())
server.go#L1040: if dl, ok := stream.Context().Deadline(); ok {
server.go#L1125: sh.HandleRPC(stream.Context(), outPayload(false, msg, data, payload, time.Now()))
server.go#L1181: sh.HandleRPC(stream.Context(), statsBegin)
server.go#L1213: sh.HandleRPC(stream.Context(), end)
server.go#L1235: ctx := stream.Context()
server.go#L1314: sh.HandleRPC(stream.Context(), &stats.InPayload{
server.go#L1335: ctx := NewContextWithServerTransportStream(stream.Context(), stream)
server.go#L1496: sh.HandleRPC(stream.Context(), statsBegin)
server.go#L1499: ctx := NewContextWithServerTransportStream(stream.Context(), stream)
server.go#L1535: sh.HandleRPC(stream.Context(), end)
stream.go#L721: return cs.attempt.s.Context()
stream.go#L1322: return as.s.Context()
stream.go#L1639: sh.HandleRPC(ss.s.Context(), outPayload(false, m, data, payload, time.Now()))
stream.go#L1694: sh.HandleRPC(ss.s.Context(), &stats.InPayload{