dgzargo's questions

我有一个事件源source，它会在短时间内产生几个事件，然后保持沉默。我几乎写了自己的实现Window，在文档中找到了实现，但偶然发现了死锁。

这是我尝试转换IObservable<T>的方式IObservable<IList<T>（将我在此期间收到的所有事件都окна放入列表中）：

source.Window(TimeSpan.FromSeconds(1)).Select(obs => obs.ToListObservable())

按照设计，它应该阻止结果事件的输出直到结束окна，但它只是死锁。

告诉我如何在不手动处理内部回调的情况下实现这一点IObservable

UPD：
我想将 2 个事件分层到一个窗口中。这样第一个事件开始窗口的倒计时，然后窗口本身通过 TimeSpan 关闭。用代码测试：

var source = Observable
    .Interval(TimeSpan.FromMilliseconds(300));

var output = source.Window(TimeSpan.FromMilliseconds(700)).SelectMany(window => window.ToList());

using var subscription = output
    .Subscribe(list => Console.WriteLine(">>" + string.Join("; ", list)));
Console.ReadLine();

UPD2：
我仍在尝试将“窗口”设置为像“开关”一样工作：打开它 - 它开始录制，关闭它 - 它结束录制并且可以打开它。

var state = false;
var output = source.Delay(TimeSpan.FromMilliseconds(50))
    .Window(source.Where(next => state == false).Select(next=>
    {
        state = true;
        return DateTime.UtcNow + TimeSpan.FromMilliseconds(610);
    }), time => source.Where(next =>
    {
        var shellEnd = time < DateTime.UtcNow;
        if (shellEnd)
        {
            state = false;
        }
        return shellEnd;
    }))
    .SelectMany(window => window.ToList());

这里仍然存在问题：

• 有时列表中有三个事件而不是两个
• 延迟Delay往往无济于事。它应该稍微延迟事件调用，以便在事件传播之前打开/关闭窗口

我读了一篇关于 ValueTask 的文章——出现了几个问题，
这里是文章中的代码：

int bytesRead;
{
    ValueTask<int> readTask = _connection.ReadAsync(buffer);
    if (readTask.IsCompletedSuccessfully)
    {
        bytesRead = readTask.Result;
    }
    else
    {
        using (_connection.RegisterCancellation())
        {
            bytesRead = await readTask;
        }
    }
}

它手动询问任务是否已结束，如果已结束，则同步执行所有操作；没有结束 - 异步。

还有一些我不明白的东西：

• 这是什么奇怪的方法_connection.RegisterCancellation()
• 并且不能编译器本身而不是一个词await分支到同步和异步的情况下。也许是新版本？也许他们没有故意把它放在编译器中？

写了一个html表单来上传数据

<form action="/bookmarks/new" method="post" enctype="multipart/form-data">
    <label>
        Text file:
        <input type="file" name="textFile"><br>
    </label>
    <label>
        Image file:
        <input type="file" name="imageFile" accept="image/jpeg"><br>
    </label>
    <label>
        Bookmark path:
        <input type="text" name="bookmarkPath">
    </label><br>
    <input type="submit" value="Загрузить"/>
</form>

和一个应该接受两个文件和一个字符串的控制器方法

[HttpPost("new")]
public async Task<IActionResult> InsertBookmark(IFormFile textFile, IFormFile imageFile, [FromBody]string bookmarkPath)

我不明白什么不起作用，它给出了一个错误415 Unsupported Media Type
如何重新制作它以便您可以发送两个文件和一行？

private bool TryParseOf<TType>(string s, out TType result)
{
    if (typeof(TType) == typeof(int))
    {
        var parseSuccessful = int.TryParse(s, out var innerResult);
        result = innerResult; // в этой строке проблема
        return parseSuccessful;
    }
    throw new NotImplementedException();
}

你不能只是把它拿走。TType也许int, string, 等等

abstract class MyClass
{
  int Param1 {get; set;} 
  int Param2 {get; set;} 
  MyClass(int param1 = 4, int param2 = 10)
  {
  this.Param1 = param1;
  this.Param2 = param2;
  }
}

class Class1 : MyClass //переопределяю значения по-умолчанию
{
  int Param3 {get; set;} 
  Class1(int param1 = 4, int param2 = 10, int param3 = 2):base(param1, param2)
  {
  this.Param3 = param3;
  }
}

需要在子类中做可选参数，不重复参数中常量的设置
；如果调用时不指定参数，则取自父构造函数

通过制作可选参数可以手动实现类似的行为：

public Class1(int param1, int param2, int param3 = 2):base(param1, param2)
{
  this.Param3 = param3;
}
public Class1(int param1, int param3 = 2):base(param1: param1)
{
  this.Param3 = param3;
}
public Class1(int param3 = 2):base()
{
  this.Param3 = param3;
}