mr5z

// interface
interface IActivityInstanceProvider {
    fun updateInstance(activity: Activity)
    fun <TActivity: Activity> get(): TActivity?
}

// class
class ActivityInstanceProvider: IActivityInstanceProvider {

    private val activityInstance: HashSet<WeakReference<Activity?>> = hashSetOf()

mr5z

internal class ObservableCollectionAndItems<TModel> where TModel : INotifyPropertyChanged
{
    private readonly ObservableCollection<TModel> collection = new();

    public event EventHandler<EventArgs>? ItemChanged;
    public event EventHandler<NotifyCollectionChangedEventArgs>? CollectionChanged;

    public ObservableCollectionAndItems()
    {
        collection.CollectionChanged += Collection_CollectionChanged;

mr5z

static std::string date_format(boost::posix_time::ptime const& datetime) {
    using namespace boost;
    std::ostringstream ss;

    auto output_facet = new boost::posix_time::time_facet();
    ss.imbue(std::locale(std::locale::classic(), output_facet));
    output_facet->format("%Y-%m-%d %H:%M:%s%Q");

    ss.str("");

mr5z

[Route("api/[controller]")]
[ApiController]
public class MonitorController : Controller
{
    private readonly IActionDescriptorCollectionProvider _provider;

    public MonitorController(IActionDescriptorCollectionProvider provider)
    {
        _provider = provider;
    }

mr5z

class Observable
{
    private object actionCollection = null!;
    private MethodInfo? methodInfo;

    public ActionCollection<TModel> From<TModel>(TModel target) where TModel : INotifyPropertyChanged
    {
        RegisterPropertyChanged(target);
        return BuildActionCollection<TModel>();
    }

mr5z

class LoggingInterceptor : HttpClientHandler
{
    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        Debug.Log("Request {0}", request.RequestUri.PathAndQuery);

        if (request.Content != null)
        {
            var contentRequest = await request.Content.ReadAsStringAsync();
        }

mr5z

public class Configuration : IConfiguration
{
    private readonly string assemblyResourceFile;
    private AutoDisposeJsonDocument? smartJsonDocument;

    public Configuration(string assemblyResourceFile)
    {
        this.assemblyResourceFile = assemblyResourceFile;
    }

mr5z

private void ScheduleDisposeResourceStreams()
{
    _ = Task.Factory.StartNew(async () =>
    {
        await Task.Delay(TimeSpan.FromMinutes(1));
        // `stream` creation happens right after the invocation of this
        // They are in the same thread so no lock needed
        jsonStream?.Dispose();
        jsonDocument?.Dispose();
        jsonStream = null;

mr5z

public async Task<T?> GetValue<T>(string path, JsonSerializerOptions? options, CancellationToken cancellationToken)
{
    using var stream = GetStream();
    using var jsonDocument = await JsonDocument.ParseAsync(stream, cancellationToken: cancellationToken);
    var root = jsonDocument.RootElement;

    var jsonPath = JsonPath.Parse(path);
    var pathResult = jsonPath.Evaluate(root);
    if (pathResult.Error != null)
        throw new InvalidOperationException(pathResult.Error);

mr5z

//Startup.cs
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    app.UseIpRateLimiting();
    app.UseClientRateLimiting();

    // the rest
}

public void ConfigureServices(IServiceCollection services)