GPG key ID:
4B9DB28F826553BD
151 changed files with
151 additions and
151 deletions
|
|
|
|
@ -117,4 +117,4 @@ internal sealed class RequestDispatcherBuilderExtensionsTests
|
|
|
|
|
await Assert.That(() => builder.Add([typeof(TestHandler)], ServiceLifetime.Transient)).Throws<ArgumentNullException>();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -108,4 +108,4 @@ internal sealed class ScalarBehaviourTests
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Moved to _fixtures
|
|
|
|
|
// Moved to _fixtures
|
|
|
|
|
|
|
|
|
|
@ -248,4 +248,4 @@ internal sealed class ScalarDispatcherTests
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Moved to _fixtures
|
|
|
|
|
// Moved to _fixtures
|
|
|
|
|
|
|
|
|
|
@ -107,4 +107,4 @@ internal sealed class StreamBehaviourTests
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Moved to _fixtures
|
|
|
|
|
// Moved to _fixtures
|
|
|
|
|
|
|
|
|
|
@ -240,4 +240,4 @@ public class StreamDispatcherTests
|
|
|
|
|
|
|
|
|
|
await Assert.That(() => options.Inspect([])).Throws<InvalidOperationException>();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -16,4 +16,4 @@ public class AmbiguousScalarHandler : IScalarRequestHandler<AmbiguousScalarReque
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult("Interface-Handled");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class AmbiguousScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -16,4 +16,4 @@ public class AmbiguousStreamHandler : IStreamRequestHandler<AmbiguousStreamReque
|
|
|
|
|
{
|
|
|
|
|
yield return "Interface-Handled";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class AmbiguousStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class AnotherNamedScalarRequest : INamedScalarRequest
|
|
|
|
|
{
|
|
|
|
|
public string Name { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class AnotherNamedStreamRequest : INamedStreamRequest
|
|
|
|
|
{
|
|
|
|
|
public string Name { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ internal sealed class AnotherTestHandler : IScalarRequestHandler<AnotherTestRequ
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult("ok");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -3,4 +3,4 @@
|
|
|
|
|
|
|
|
|
|
namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
internal sealed class AnotherTestRequest : IScalarRequest<string> { }
|
|
|
|
|
internal sealed class AnotherTestRequest : IScalarRequest<string> { }
|
|
|
|
|
|
|
|
|
|
@ -7,4 +7,4 @@ public abstract class BaseScalarHandler<TRequest> : IScalarRequestHandler<TReque
|
|
|
|
|
where TRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public abstract Task<string> HandleAsync(TRequest request, CancellationToken cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -7,4 +7,4 @@ public abstract class BaseStreamHandler<TRequest> : IStreamRequestHandler<TReque
|
|
|
|
|
where TRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public abstract IAsyncEnumerable<string> HandleAsync(TRequest request, CancellationToken cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class ConstrainedScalarHandler<TRequest> : IScalarRequestHandler<TRequest
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"{request.Value}-Constrained");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class ConstrainedScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public int Value { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ public class ConstrainedStreamHandler<TRequest> : IStreamRequestHandler<TRequest
|
|
|
|
|
yield return $"{request.Value}-Constrained-0";
|
|
|
|
|
yield return $"{request.Value}-Constrained-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class ConstrainedStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public int Value { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class DeepDerivedScalarRequest : InheritedScalarRequest
|
|
|
|
|
{
|
|
|
|
|
public int DeepValue { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class DeepDerivedStreamRequest : InheritedStreamRequest
|
|
|
|
|
{
|
|
|
|
|
public int DeepValue { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class DerivedScalarHandler : BaseScalarHandler<DerivedScalarRequest>
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"Derived: {request.Value}");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class DerivedScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public int Value { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class DerivedStreamHandler : BaseStreamHandler<DerivedStreamRequest>
|
|
|
|
|
yield return $"Derived: {request.Value}-0";
|
|
|
|
|
yield return $"Derived: {request.Value}-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class DerivedStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public int Value { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class ExplicitGenericScalarHandler<T> : IScalarRequestHandler<ExplicitGen
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"{request.Value}-ExplicitHandled");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class ExplicitGenericScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public string Value { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class ExplicitGenericStreamHandler<T> : IStreamRequestHandler<ExplicitGen
|
|
|
|
|
{
|
|
|
|
|
yield return $"{request.Value}-ExplicitHandled";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class ExplicitGenericStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public string Value { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class FailingScalarHandler : IScalarRequestHandler<FailingScalarRequest,
|
|
|
|
|
{
|
|
|
|
|
throw new InvalidOperationException("Handler failed");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class FailingScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class FailingStreamHandler : IStreamRequestHandler<FailingStreamRequest,
|
|
|
|
|
yield return "Wait for it...";
|
|
|
|
|
throw new InvalidOperationException("Handler failed");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class FailingStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public interface INamedScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
string Name { get; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public interface INamedStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
string Name { get; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class InheritedScalarRequest : OpenScalarRequest
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class InheritedStreamRequest : OpenStreamRequest
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class InterfaceConstrainedScalarHandler<TRequest> : IScalarRequestHandler
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"{request.Name}-ConstrainedByInterface");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ public class InterfaceConstrainedStreamHandler<TRequest> : IStreamRequestHandler
|
|
|
|
|
yield return $"{request.Name}-ConstrainedByInterface-0";
|
|
|
|
|
yield return $"{request.Name}-ConstrainedByInterface-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class InterfaceInheritedScalarHandler : IScalarRequestHandler<InterfaceIn
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"{request.Name}-InterfaceHandled");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class InterfaceInheritedScalarRequest : INamedScalarRequest
|
|
|
|
|
{
|
|
|
|
|
public string Name { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class InterfaceInheritedStreamHandler : IStreamRequestHandler<InterfaceIn
|
|
|
|
|
yield return $"{request.Name}-InterfaceHandled-0";
|
|
|
|
|
yield return $"{request.Name}-InterfaceHandled-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class InterfaceInheritedStreamRequest : INamedStreamRequest
|
|
|
|
|
{
|
|
|
|
|
public string Name { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -14,4 +14,4 @@ public class MultiInterfaceScalarHandler : IScalarRequestHandler<MultiInterfaceS
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult("One");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class MultiInterfaceScalarRequest : IScalarRequest<int>, IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -16,4 +16,4 @@ public class MultiInterfaceStreamHandler : IStreamRequestHandler<MultiInterfaceS
|
|
|
|
|
yield return "One";
|
|
|
|
|
yield return "Two";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class MultiInterfaceStreamRequest : IStreamRequest<int>, IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ where TRequest : OpenScalarRequest
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"{request.Data}-Handled");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class OpenScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public string Data { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ public class OpenStreamHandler<TRequest> : IStreamRequestHandler<TRequest, strin
|
|
|
|
|
yield return $"{request.Data}-Stream-0";
|
|
|
|
|
yield return $"{request.Data}-Stream-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class OpenStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public string Data { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class ScalarChainedBehaviour1(ScalarTestTracker tracker) : IScalarRequest
|
|
|
|
|
tracker.Log.Add("Behaviour1");
|
|
|
|
|
return await next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class ScalarChainedBehaviour2(ScalarTestTracker tracker) : IScalarRequest
|
|
|
|
|
tracker.Log.Add("Behaviour2");
|
|
|
|
|
return await next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ where TRequest : IScalarRequest<TResponse>
|
|
|
|
|
tracker.Executed = true;
|
|
|
|
|
return await next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class ScalarOrderingClosedBehavior(ScalarTestTracker tracker) : IScalarRe
|
|
|
|
|
tracker.Log.Add("OrderingClosed");
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ where TRequest : IScalarRequest<TOutput>
|
|
|
|
|
tracker.Log.Add("OrderingOpen");
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class ScalarTestBehavior(ScalarTestTracker tracker) : IScalarRequestBehav
|
|
|
|
|
tracker.Executed = true;
|
|
|
|
|
return await next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class ScalarTestHandler : IScalarRequestHandler<ScalarTestRequest, string
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"{request.Value}-Handled");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class ScalarTestRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public string Value { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -7,4 +7,4 @@ public class ScalarTestTracker
|
|
|
|
|
{
|
|
|
|
|
public List<string> Log { get; } = [];
|
|
|
|
|
public bool Executed { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class ScalarTestWrapperHandler<T> : IScalarRequestHandler<ScalarTestWrapp
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"Handled-{request.Item}");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class ScalarTestWrapperRequest<T> : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public T Item { get; set; } = default!;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class ScalarWrapperBehavior<T>(ScalarTestTracker tracker) : IScalarReques
|
|
|
|
|
tracker.Executed = true;
|
|
|
|
|
return await next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamChainedBehaviour1(StreamTestTracker tracker) : IStreamRequest
|
|
|
|
|
tracker.Log.Add("Behaviour1");
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamChainedBehaviour2(StreamTestTracker tracker) : IStreamRequest
|
|
|
|
|
tracker.Log.Add("Behaviour2");
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ where TRequest : IStreamRequest<TResponse>
|
|
|
|
|
tracker.Executed = true;
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamOrderingClosedBehavior(StreamTestTracker tracker) : IStreamRe
|
|
|
|
|
tracker.Log.Add("Closed");
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -11,4 +11,4 @@ where TRequest : IStreamRequest<TOutput>
|
|
|
|
|
tracker.Log.Add("Open");
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamTestBehavior(StreamTestTracker tracker) : IStreamRequestBehav
|
|
|
|
|
tracker.Executed = true;
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamTestHandler : IStreamRequestHandler<StreamTestRequest, string
|
|
|
|
|
yield return $"{request.Value}-Handled-0";
|
|
|
|
|
yield return $"{request.Value}-Handled-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class StreamTestRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public string Value { get; set; } = string.Empty;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -7,4 +7,4 @@ public class StreamTestTracker
|
|
|
|
|
{
|
|
|
|
|
public List<string> Log { get; } = [];
|
|
|
|
|
public bool Executed { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamTestWrapperHandler<T> : IStreamRequestHandler<StreamTestWrapp
|
|
|
|
|
yield return $"Handled-{request.Item}-0";
|
|
|
|
|
yield return $"Handled-{request.Item}-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class StreamTestWrapperRequest<T> : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public T? Item { get; set; }
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class StreamWrapperBehavior<T>(StreamTestTracker tracker) : IStreamReques
|
|
|
|
|
tracker.Executed = true;
|
|
|
|
|
return next(request, cancellationToken);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ internal sealed class TestHandler : IScalarRequestHandler<TestRequest, string>
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult("ok");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -3,4 +3,4 @@
|
|
|
|
|
|
|
|
|
|
namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
internal sealed class TestRequest : IScalarRequest<string> { }
|
|
|
|
|
internal sealed class TestRequest : IScalarRequest<string> { }
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class UnhandledScalarRequest : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -5,4 +5,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
|
|
|
|
|
public class UnhandledStreamRequest : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -9,4 +9,4 @@ public class WrapperScalarHandler<T> : IScalarRequestHandler<WrapperScalarReques
|
|
|
|
|
{
|
|
|
|
|
return Task.FromResult($"Handled-{request.Item}");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class WrapperScalarRequest<T> : IScalarRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public T Item { get; set; } = default!;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -10,4 +10,4 @@ public class WrapperStreamHandler<T> : IStreamRequestHandler<WrapperStreamReques
|
|
|
|
|
yield return $"Handled-{request.Item}-0";
|
|
|
|
|
yield return $"Handled-{request.Item}-1";
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -6,4 +6,4 @@ namespace Geekeey.Request.Tests;
|
|
|
|
|
public class WrapperStreamRequest<T> : IStreamRequest<string>
|
|
|
|
|
{
|
|
|
|
|
public T Item { get; set; } = default!;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|