Существует ли способ определить на клиенте, что сервер преждевременно завершил вызов потоковой передачи от клиента, вернув ответ?

Question 1

У меня следующий случай. Клиент загружает файлы на сервер с использованием клиентского стриминга (через grpc-dotnet). В некоторых случаях сервер может решить игнорировать клиентский поток и сразу вернуть ответ. Поскольку клиент не осведомлен о решении сервера, он продолжает вызывать RequestStream.WriteAsync() и в конечном итоге получает Grpc.Core.RpcException: 'Status(StatusCode="OK", Detail="")'

Вопрос: существует ли элегантный способ заранее узнать, что вызов уже завершен, не совершая ошибочных попыток записи?

Просматривая исходный код grpc-dotnet, я смог найти решение через рефлексию AsyncClientStreamingCall.RequestStream.Call.ResponseFinished, но это выглядит еще хуже, чем обработка исключения с известным StatusCode.

Псевдокод клиента:

private static async Task CallUploadStream(GrpcService.GrpcServiceClient client)
{
    using var streamingCall = client.UploadStream();

    // Первый вызов
    await WriteAsync();

    // Задержка
    await Task.Delay(TimeSpan.FromSeconds(1));

    // Второй вызов
    await WriteAsync(); // Grpc.Core.RpcException: 'Status(StatusCode="OK", Detail="")'

    await streamingCall.RequestStream.CompleteAsync();
    await streamingCall;

    return;

    Task WriteAsync()
    {
        return streamingCall.RequestStream.WriteAsync(
            new UploadStreamRequest
            {
                Bytes = ByteString.CopyFrom(new byte[1]),
            }
        );
    }
}

Контракт Protobuf:

syntax = "proto3";
package grpc.debug.contract.v1;
option csharp_namespace = "GrpcDebug.Contract";
import "google/protobuf/empty.proto";

service GrpcService {
  rpc UploadStream(stream UploadStreamRequest) returns (google.protobuf.Empty);
}

message UploadStreamRequest { bytes bytes = 1; }

Сервер, который сразу возвращает ответ:

public class GrpcServiceV1 : GrpcService.GrpcServiceBase
{
    public override Task<Empty> UploadStream(IAsyncStreamReader<UploadStreamRequest> requestStream,
        ServerCallContext context)
    {
        return Task.FromResult(new Empty());
    }
}

Question 2

Чтобы прояснить: действительно ли вызов WriteAsync завершается с ошибкой RpcException? Вы можете попробовать проверить call.ResponseAsync.IsCompleted перед каждой записью (или, возможно, перед каждой частью работы, чтобы получить следующий кусок), однако это по своей сути гонка условий, и вы всегда должны быть готовы ловить исключение даже если вы проверяете в строке перед этим. Если то, что вы здесь эмулируете, по сути является потоком, или, по крайней мере: вы отправляете большой полезный груз несколькими частями, тогда вам, возможно, также будет интересно поработать с protobuf-net.Grpc, чтобы добавить поддержку бинарного стриминга нативно; в версии на NuGet это в настоящее время ограничивается серверами, возвращающими Stream, но это в основном потому, что это сценарий, в котором потребитель срочно нуждался – планируется добавить все комбинации направлений и поддержку для API, отличных от Stream, таких как Pipe и т.д.

Существует ли способ определить на клиенте, что сервер преждевременно завершил вызов потоковой передачи от клиента, вернув ответ?

Вопрос или проблема

Ответ или решение

Как распознать завершение вызова заранее

Заключение