in src/Epam.Kafka.PubSub/Utils/ActivityWrapper.cs [42:84]
public void SetResult(object? value)
{
if (this._listener.IsEnabled() && value is IEnumerable enumerable and not string)
{
var sb = new StringBuilder(128);
bool separator = false;
foreach (object obj in enumerable)
{
if (separator)
{
sb.Append(';');
}
sb.Append(obj);
separator = true;
}
value = sb.ToString();
}
this._activity.SetCustomProperty(Result, value);
if (value is Exception exception)
{
this._activity.SetStatus(ActivityStatusCode.Error, exception.GetType().Name);
}
else
{
string? description = null;
if (value is Enum en)
{
description = en.ToString("G");
this._activity.SetTag(Result, description);
}
this._activity.SetStatus(ActivityStatusCode.Ok, description);
}
}