google.golang.org/grpc.csAttempt.s (field)

34 uses

	google.golang.org/grpc (current package)
		rpc_util.go#L208: 	*o.HeaderAddr, _ = attempt.s.Header()
		rpc_util.go#L226: 	*o.TrailerAddr = attempt.s.Trailer()
		rpc_util.go#L244: 	if x, ok := peer.FromContext(attempt.s.Context()); ok {
		stream.go#L384: 	cs.attempt.s = s
		stream.go#L445: 	s    *transport.Stream
		stream.go#L478: 	if cs.attempt.s == nil {
		stream.go#L498: 	if cs.attempt.s != nil {
		stream.go#L499: 		<-cs.attempt.s.Done()
		stream.go#L500: 		unprocessed = cs.attempt.s.Unprocessed()
		stream.go#L512: 	if cs.attempt.s != nil {
		stream.go#L513: 		if !cs.attempt.s.TrailersOnly() {
		stream.go#L519: 		sps := cs.attempt.s.Trailer()["grpc-retry-pushback-ms"]
		stream.go#L536: 	if cs.attempt.s != nil {
		stream.go#L537: 		code = cs.attempt.s.Status().Code()
		stream.go#L605: 	return cs.attempt.s.Context()
		stream.go#L624: 			<-a.s.Done()
		stream.go#L626: 		if err == nil || (err == io.EOF && a.s.Status().Code() == codes.OK) {
		stream.go#L642: 		m, err = a.s.Header()
		stream.go#L674: 	if cs.attempt.s == nil {
		stream.go#L677: 	return cs.attempt.s.Trailer()
		stream.go#L797: 		a.t.Write(a.s, nil, nil, &transport.Options{Last: true})
		stream.go#L829: 		if cs.attempt.s != nil {
		stream.go#L868: 	if err := a.t.Write(a.s, hdr, payld, &transport.Options{Last: !cs.desc.ClientStreams}); err != nil {
		stream.go#L894: 		if ct := a.s.RecvCompress(); ct != "" && ct != encoding.Identity {
		stream.go#L908: 	err = recv(a.p, cs.codec, a.s, a.dc, m, *cs.callInfo.maxReceiveMessageSize, payInfo, a.decomp)
		stream.go#L911: 			if statusErr := a.s.Status().Err(); statusErr != nil {
		stream.go#L945: 	err = recv(a.p, cs.codec, a.s, a.dc, m, *cs.callInfo.maxReceiveMessageSize, nil, a.decomp)
		stream.go#L950: 		return a.s.Status().Err() // non-server streaming Recv returns nil on success
		stream.go#L967: 	if a.s != nil {
		stream.go#L968: 		a.t.CloseStream(a.s, err)
		stream.go#L969: 		tr = a.s.Trailer()
		stream.go#L974: 		if a.s != nil {
		stream.go#L975: 			br = a.s.BytesReceived()
		stream.go#L980: 			BytesSent:     a.s != nil,