geekeey/request
Watch
2
0
Fork
You've already forked request
 0
Code Issues Pull requests Projects Releases Packages 3 Wiki Activity Actions

feat: hide pipelines internals from stack trace
All checks were successful
default / dotnet-default-workflow (pull_request) Successful in 2m4s
Details
default / dotnet-default-workflow (push) Successful in 1m59s
Details

Browse source
This commit is contained in:
Louis Seubert 2026-05-29 22:53:58 +02:00
commit 4d33d5ab4c
Signed by: louis9902
GPG key ID: 4B9DB28F826553BD
5 changed files with 87 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/request.dispatcher.tests/_fixtures/StreamOpenBehavior.cs
View file

@ -1,14 +1,19 @@
// Copyright (c) The Geekeey Authors
// SPDX-License-Identifier: EUPL-1.2
using System.Runtime.CompilerServices;
namespace Geekeey.Request.Dispatcher.Tests;
public class StreamOpenBehavior<TRequest, TResponse>(StreamTestTracker tracker) : IStreamRequestBehavior<TRequest, TResponse>
where TRequest : IStreamRequest<TResponse>
{
public IAsyncEnumerable<TResponse> HandleAsync(TRequest request, StreamHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
public async IAsyncEnumerable<TResponse> HandleAsync(TRequest request, StreamHandlerDelegate<TResponse> next, [EnumeratorCancellation] CancellationToken cancellationToken)
{
tracker.Executed = true;
return next(request, cancellationToken);
await foreach (var response in next(request, cancellationToken))
{
yield return response;
}
}
}