type google.golang.org/grpc/internal/transport.ServerStream
53 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L228: func (ht *serverHandlerTransport) writeStatus(s *ServerStream, st *status.Status) error {
handler_server.go#L292: func (ht *serverHandlerTransport) writePendingHeaders(s *ServerStream) {
handler_server.go#L299: func (ht *serverHandlerTransport) writeCommonHeaders(s *ServerStream) {
handler_server.go#L320: func (ht *serverHandlerTransport) writeCustomHeaders(s *ServerStream) {
handler_server.go#L336: func (ht *serverHandlerTransport) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
handler_server.go#L360: func (ht *serverHandlerTransport) writeHeader(s *ServerStream, md metadata.MD) error {
handler_server.go#L388: func (ht *serverHandlerTransport) HandleStreams(ctx context.Context, startStream func(*ServerStream)) {
handler_server.go#L411: s := &ServerStream{
http2_server.go#L116: activeStreams map[uint32]*ServerStream
http2_server.go#L262: activeStreams: make(map[uint32]*ServerStream),
http2_server.go#L368: func (t *http2Server) operateHeaders(ctx context.Context, frame *http2.MetaHeadersFrame, handle func(*ServerStream)) error {
http2_server.go#L394: s := &ServerStream{
http2_server.go#L670: func (t *http2Server) HandleStreams(ctx context.Context, handle func(*ServerStream)) {
http2_server.go#L734: func (t *http2Server) getStream(f http2.Frame) (*ServerStream, bool) {
http2_server.go#L752: func (t *http2Server) adjustWindow(s *ServerStream, n uint32) {
http2_server.go#L762: func (t *http2Server) updateWindow(s *ServerStream, n uint32) {
http2_server.go#L999: func (t *http2Server) streamContextErr(s *ServerStream) error {
http2_server.go#L1009: func (t *http2Server) writeHeader(s *ServerStream, md metadata.MD) error {
http2_server.go#L1038: func (t *http2Server) writeHeaderLocked(s *ServerStream) error {
http2_server.go#L1078: func (t *http2Server) writeStatus(s *ServerStream, st *status.Status) error {
http2_server.go#L1149: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
http2_server.go#L1306: func (t *http2Server) deleteStream(s *ServerStream, eosReceived bool) {
http2_server.go#L1326: func (t *http2Server) finishStream(s *ServerStream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
http2_server.go#L1350: func (t *http2Server) closeStream(s *ServerStream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
server_stream.go#L34: type ServerStream struct {
server_stream.go#L55: func (s *ServerStream) Read(n int) (mem.BufferSlice, error) {
server_stream.go#L64: func (s *ServerStream) SendHeader(md metadata.MD) error {
server_stream.go#L69: func (s *ServerStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
server_stream.go#L75: func (s *ServerStream) WriteStatus(st *status.Status) error {
server_stream.go#L80: func (s *ServerStream) isHeaderSent() bool {
server_stream.go#L86: func (s *ServerStream) updateHeaderSent() bool {
server_stream.go#L92: func (s *ServerStream) RecvCompress() string {
server_stream.go#L97: func (s *ServerStream) SendCompress() string {
server_stream.go#L106: func (s *ServerStream) ContentSubtype() string {
server_stream.go#L111: func (s *ServerStream) SetSendCompress(name string) error {
server_stream.go#L122: func (s *ServerStream) SetContext(ctx context.Context) {
server_stream.go#L128: func (s *ServerStream) ClientAdvertisedCompressors() []string {
server_stream.go#L139: func (s *ServerStream) Header() (metadata.MD, error) {
server_stream.go#L147: func (s *ServerStream) HeaderWireLength() int {
server_stream.go#L153: func (s *ServerStream) SetHeader(md metadata.MD) error {
server_stream.go#L169: func (s *ServerStream) SetTrailer(md metadata.MD) error {
transport.go#L598: HandleStreams(context.Context, func(*ServerStream))
transport.go#L614: writeHeader(s *ServerStream, md metadata.MD) error
transport.go#L615: write(s *ServerStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error
transport.go#L616: writeStatus(s *ServerStream, st *status.Status) error
google.golang.org/grpc
server.go#L1055: st.HandleStreams(ctx, func(stream *transport.ServerStream) {
server.go#L1171: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1247: func (s *Server) processUnaryRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1578: func (s *Server) processStreamingRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1775: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.ServerStream) {
server.go#L2140: stream, ok := ServerTransportStreamFromContext(ctx).(*transport.ServerStream)
server.go#L2162: stream, ok := ServerTransportStreamFromContext(ctx).(*transport.ServerStream)
stream.go#L1586: s *transport.ServerStream