google.golang.org/grpc.addrConnStream.s (field)
14 uses
google.golang.org/grpc (current package)
stream.go#L1098: as.s = s
stream.go#L1120: s *transport.Stream
stream.go#L1142: m, err := as.s.Header()
stream.go#L1150: return as.s.Trailer()
stream.go#L1160: as.t.Write(as.s, nil, nil, &transport.Options{Last: true})
stream.go#L1169: return as.s.Context()
stream.go#L1201: if err := as.t.Write(as.s, hdr, payld, &transport.Options{Last: !as.desc.ClientStreams}); err != nil {
stream.go#L1227: if ct := as.s.RecvCompress(); ct != "" && ct != encoding.Identity {
stream.go#L1241: err = recv(as.p, as.codec, as.s, as.dc, m, *as.callInfo.maxReceiveMessageSize, nil, as.decomp)
stream.go#L1244: if statusErr := as.s.Status().Err(); statusErr != nil {
stream.go#L1262: err = recv(as.p, as.codec, as.s, as.dc, m, *as.callInfo.maxReceiveMessageSize, nil, as.decomp)
stream.go#L1267: return as.s.Status().Err() // non-server streaming Recv returns nil on success
stream.go#L1283: if as.s != nil {
stream.go#L1284: as.t.CloseStream(as.s, err)
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |