Function unwrapErrorStreamClientInterceptor

pkg/util/grpcclient/unwrap.go:11–22

unwrapErrorStreamClientInterceptor unwraps errors wrapped by OpenTracingStreamClientInterceptor

()

// unwrapErrorStreamClientInterceptor unwraps errors wrapped by OpenTracingStreamClientInterceptor
func unwrapErrorStreamClientInterceptor() grpc.StreamClientInterceptor {
	return func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
		stream, err := streamer(ctx, desc, cc, method, opts...)
		if err != nil {
			return nil, err
		}

		return &unwrapErrorClientStream{
			ClientStream: stream,
		}, nil
	}
}

type unwrapErrorClientStream struct {
	grpc.ClientStream