protoutil

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

func MonitorStreamHealth[Req any](
	ctx context.Context,
	log *zap.Logger,
	streamer grpc.ServerStream,
	validFn func(*Req) 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