geekeey/request
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 3 Wiki Activity Actions

Compare commits

base: geekeey:5c2911ea6c8f4fff7d8b9b88e7f994e1041f0d4e
Branches Tags
geekeey:main
geekeey:2.0.0
geekeey:1.1.0
geekeey:1.0.0
..
compare: geekeey:4d33d5ab4c9447d1818252fcdea511674c53cef9
Branches Tags
geekeey:main
geekeey:2.0.0
geekeey:1.1.0
geekeey:1.0.0

1 commit
5c2911ea6c ... 4d33d5ab4c

Author SHA1 Message Date
Louis Seubert
4d33d5ab4c
 		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
2026-05-29 23:10:01 +02:00
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1,12 +1,14 @@
// Copyright (c) The Geekeey Authors // Copyright (c) The Geekeey Authors
// SPDX-License-Identifier: EUPL-1.2 // SPDX-License-Identifier: EUPL-1.2
using System.Runtime.CompilerServices;
namespace Geekeey.Request.Dispatcher.Tests; namespace Geekeey.Request.Dispatcher.Tests;
public class StreamOpenBehavior<TRequest, TResponse>(StreamTestTracker tracker) : IStreamRequestBehavior<TRequest, TResponse> public class StreamOpenBehavior<TRequest, TResponse>(StreamTestTracker tracker) : IStreamRequestBehavior<TRequest, TResponse>
where TRequest : IStreamRequest<TResponse> where TRequest : IStreamRequest<TResponse>
{ {
public async 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; tracker.Executed = true;
await foreach (var response in next(request, cancellationToken)) await foreach (var response in next(request, cancellationToken))