MCPcopy
hub / github.com/grpc/grpc-go / Unprocessed

Method Unprocessed

internal/transport/client_stream.go:125–127  ·  view source on GitHub ↗

Unprocessed indicates whether the server did not process this stream -- i.e. it sent a refused stream or GOAWAY including this stream ID.

()

Source from the content-addressed store, hash-verified

123// Unprocessed indicates whether the server did not process this stream --
124// i.e. it sent a refused stream or GOAWAY including this stream ID.
125func (s *ClientStream) Unprocessed() bool {
126 return s.unprocessed.Load()
127}
128
129func (s *ClientStream) waitOnHeader() {
130 select {

Callers 1

shouldRetryMethod · 0.80

Implementers 3

clientStreamstream.go
okStreaminternal/xds/httpfilter/fault/fault.go

Calls 1

LoadMethod · 0.45

Tested by

no test coverage detected