type google.golang.org/grpc/internal/transport.Stream

78 uses

	google.golang.org/grpc/internal/transport (current package)
		handler_server.go#L185: func (ht *serverHandlerTransport) WriteStatus(s *Stream, st *status.Status) error {
		handler_server.go#L246: func (ht *serverHandlerTransport) writePendingHeaders(s *Stream) {
		handler_server.go#L253: func (ht *serverHandlerTransport) writeCommonHeaders(s *Stream) {
		handler_server.go#L274: func (ht *serverHandlerTransport) writeCustomHeaders(s *Stream) {
		handler_server.go#L290: func (ht *serverHandlerTransport) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
		handler_server.go#L302: func (ht *serverHandlerTransport) WriteHeader(s *Stream, md metadata.MD) error {
		handler_server.go#L330: func (ht *serverHandlerTransport) HandleStreams(startStream func(*Stream), traceCtx func(context.Context, string) context.Context) {
		handler_server.go#L355: 	s := &Stream{
		http2_client.go#L111: 	activeStreams map[uint32]*Stream
		http2_client.go#L262: 		activeStreams:         make(map[uint32]*Stream),
		http2_client.go#L372: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *Stream {
		http2_client.go#L374: 	s := &Stream{
		http2_client.go#L582: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Stream, err error) {
		http2_client.go#L731: func (t *http2Client) CloseStream(s *Stream, err error) {
		http2_client.go#L743: func (t *http2Client) closeStream(s *Stream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
		http2_client.go#L870: func (t *http2Client) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
		http2_client.go#L893: func (t *http2Client) getStream(f http2.Frame) *Stream {
		http2_client.go#L903: func (t *http2Client) adjustWindow(s *Stream, n uint32) {
		http2_client.go#L912: func (t *http2Client) updateWindow(s *Stream, n uint32) {
		http2_server.go#L112: 	activeStreams map[uint32]*Stream
		http2_server.go#L227: 		activeStreams:     make(map[uint32]*Stream),
		http2_server.go#L304: func (t *http2Server) operateHeaders(frame *http2.MetaHeadersFrame, handle func(*Stream), traceCtx func(context.Context, string) context.Context) (fatal bool) {
		http2_server.go#L322: 	s := &Stream{
		http2_server.go#L455: func (t *http2Server) HandleStreams(handle func(*Stream), traceCtx func(context.Context, string) context.Context) {
		http2_server.go#L517: func (t *http2Server) getStream(f http2.Frame) (*Stream, bool) {
		http2_server.go#L535: func (t *http2Server) adjustWindow(s *Stream, n uint32) {
		http2_server.go#L545: func (t *http2Server) updateWindow(s *Stream, n uint32) {
		http2_server.go#L783: func (t *http2Server) WriteHeader(s *Stream, md metadata.MD) error {
		http2_server.go#L807: func (t *http2Server) writeHeaderLocked(s *Stream) error {
		http2_server.go#L846: func (t *http2Server) WriteStatus(s *Stream, st *status.Status) error {
		http2_server.go#L910: func (t *http2Server) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
		http2_server.go#L1080: func (t *http2Server) deleteStream(s *Stream, eosReceived bool) {
		http2_server.go#L1105: func (t *http2Server) finishStream(s *Stream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
		http2_server.go#L1124: func (t *http2Server) closeStream(s *Stream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
		transport.go#L237: type Stream struct {
		transport.go#L293: func (s *Stream) isHeaderSent() bool {
		transport.go#L299: func (s *Stream) updateHeaderSent() bool {
		transport.go#L303: func (s *Stream) swapState(st streamState) streamState {
		transport.go#L307: func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
		transport.go#L311: func (s *Stream) getState() streamState {
		transport.go#L315: func (s *Stream) waitOnHeader() {
		transport.go#L335: func (s *Stream) RecvCompress() string {
		transport.go#L341: func (s *Stream) SetSendCompress(str string) {
		transport.go#L347: func (s *Stream) Done() <-chan struct{} {
		transport.go#L359: func (s *Stream) Header() (metadata.MD, error) {
		transport.go#L375: func (s *Stream) TrailersOnly() bool {
		transport.go#L385: func (s *Stream) Trailer() metadata.MD {
		transport.go#L395: func (s *Stream) ContentSubtype() string {
		transport.go#L400: func (s *Stream) Context() context.Context {
		transport.go#L405: func (s *Stream) Method() string {
		transport.go#L412: func (s *Stream) Status() *status.Status {
		transport.go#L419: func (s *Stream) SetHeader(md metadata.MD) error {
		transport.go#L435: func (s *Stream) SendHeader(md metadata.MD) error {
		transport.go#L442: func (s *Stream) SetTrailer(md metadata.MD) error {
		transport.go#L455: func (s *Stream) write(m recvMsg) {
		transport.go#L460: func (s *Stream) Read(p []byte) (n int, err error) {
		transport.go#L492: func (s *Stream) BytesReceived() bool {
		transport.go#L498: func (s *Stream) Unprocessed() bool {
		transport.go#L504: func (s *Stream) GoString() string {
		transport.go#L631: 	Write(s *Stream, hdr []byte, data []byte, opts *Options) error
		transport.go#L634: 	NewStream(ctx context.Context, callHdr *CallHdr) (*Stream, error)
		transport.go#L640: 	CloseStream(stream *Stream, err error)
		transport.go#L674: 	HandleStreams(func(*Stream), func(context.Context, string) context.Context)
		transport.go#L678: 	WriteHeader(s *Stream, md metadata.MD) error
		transport.go#L682: 	Write(s *Stream, hdr []byte, data []byte, opts *Options) error
		transport.go#L686: 	WriteStatus(s *Stream, st *status.Status) error

	google.golang.org/grpc
		rpc_util.go#L633: func recvAndDecompress(p *parser, s *transport.Stream, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) ([]byte, error) {
		rpc_util.go#L701: func recv(p *parser, c baseCodec, s *transport.Stream, dc Decompressor, m interface{}, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) error {
		server.go#L96: 	stream *transport.Stream
		server.go#L843: 	st.HandleStreams(func(stream *transport.Stream) {
		server.go#L913: func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceInfo) {
		server.go#L982: func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
		server.go#L1039: func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
		server.go#L1320: func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
		server.go#L1487: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.Stream, trInfo *traceInfo) {
		stream.go#L445: 	s    *transport.Stream
		stream.go#L1120: 	s         *transport.Stream
		stream.go#L1347: 	s     *transport.Stream