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

17 uses

	google.golang.org/grpc/internal/transport (current package)
		handler_server.go#L69: 	st := &serverHandlerTransport{
		handler_server.go#L115: type serverHandlerTransport struct {
		handler_server.go#L144: func (ht *serverHandlerTransport) Close() error {
		handler_server.go#L149: func (ht *serverHandlerTransport) closeCloseChanOnce() { close(ht.closedCh) }
		handler_server.go#L151: func (ht *serverHandlerTransport) RemoteAddr() net.Addr { return strAddr(ht.req.RemoteAddr) }
		handler_server.go#L176: func (ht *serverHandlerTransport) do(fn func()) error {
		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#L424: func (ht *serverHandlerTransport) runStream() {
		handler_server.go#L435: func (ht *serverHandlerTransport) IncrMsgSent() {}
		handler_server.go#L437: func (ht *serverHandlerTransport) IncrMsgRecv() {}
		handler_server.go#L439: func (ht *serverHandlerTransport) Drain() {