MCPcopy
hub / github.com/grpc/grpc-go / goAwayHandler

Method goAwayHandler

internal/transport/controlbuf.go:863–873  ·  view source on GitHub ↗
(g *goAway)

Source from the content-addressed store, hash-verified

861}
862
863func (l *loopyWriter) goAwayHandler(g *goAway) error {
864 // Handling of outgoing GoAway is very specific to side.
865 if l.ssGoAwayHandler != nil {
866 draining, err := l.ssGoAwayHandler(g)
867 if err != nil {
868 return err
869 }
870 l.draining = draining
871 }
872 return nil
873}
874
875func (l *loopyWriter) handle(i any) error {
876 switch i := i.(type) {

Callers 1

handleMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected