Lines Matching refs:gRPCStream

97 	gRPCStream  pb.Watch_WatchServer  member
131 		gRPCStream:  stream,
179 	authInfo, err := sws.ag.AuthInfoFromCtx(sws.gRPCStream.Context())
193 		req, err := sws.gRPCStream.Recv()
377 				serr = sws.gRPCStream.Send(wr)
379 				serr = sendFragments(wr, sws.maxRequestBytes, sws.gRPCStream.Send)
383 				if isClientCtxErr(sws.gRPCStream.Context().Err(), serr) {
403 			if err := sws.gRPCStream.Send(c); err != nil {
404 				if isClientCtxErr(sws.gRPCStream.Context().Err(), err) {
423 					if err := sws.gRPCStream.Send(v); err != nil {
424 						if isClientCtxErr(sws.gRPCStream.Context().Err(), err) {