protoutil

func BoundedReceive[Req any, ReqPtr Ptr[Req]](
	ctx context.Context,
	stream grpc.ServerStream,
	timeout time.Duration,
) (ReqPtr, error)

func MonitorStreamHealth[Req any, ReqPtr Ptr[Req]](
	ctx context.Context,
	log *zap.Logger,
	streamer grpc.ServerStream,
	validFn func(ReqPtr) bool,
) <-chan struct{}

func ProtoEqualError(a, b proto.Message) error

func SetEqualError[T proto.Message](a, b []T) error

func SliceClone[T proto.Message](src []T) []T

func SliceEqualError[T proto.Message](a, b []T) error