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

Compare commits

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

1 commit
4d33d5ab4c ... 5c2911ea6c

Author SHA1 Message Date
Louis Seubert
5c2911ea6c
 		feat: hide pipelines internals from stack trace
Some checks failed
default / dotnet-default-workflow (pull_request) Failing after 3m2s
Details
2026-05-29 22:53:58 +02:00
1 changed files with 1 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1,14 +1,12 @@
// 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, [EnumeratorCancellation] CancellationToken cancellationToken) public async IAsyncEnumerable<TResponse> HandleAsync(TRequest request, StreamHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
{ {
tracker.Executed = true; tracker.Executed = true;
await foreach (var response in next(request, cancellationToken)) await foreach (var response in next(request, cancellationToken))