Function endOfClientStream

stream.go:188–202

endOfClientStream performs cleanup actions required for both successful and failed streams. This includes incrementing channelz stats and invoking all registered OnFinish call options.

(cc *ClientConn, err error, opts ...CallOption)

// failed streams. This includes incrementing channelz stats and invoking all
// registered OnFinish call options.
func endOfClientStream(cc *ClientConn, err error, opts ...CallOption) {
	if channelz.IsOn() {
		if err != nil {
			cc.incrCallsFailed()
		} else {
			cc.incrCallsSucceeded()
		}
	}

	for _, o := range opts {
		if o, ok := o.(OnFinishCallOption); ok {
			o.OnFinish(err)
		}
	}
}

func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
	if channelz.IsOn() {