Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/All.slnx
Original file line number Diff line number Diff line change
Expand Up @@ -347,6 +347,7 @@
<Project Path="Mocha/src/Mocha.Outbox/Mocha.Outbox.csproj" />
<Project Path="Mocha/src/Mocha.Threading/Mocha.Threading.csproj" />
<Project Path="Mocha/src/Mocha.Transport.InMemory/Mocha.Transport.InMemory.csproj" />
<Project Path="Mocha/src/Mocha.Utilities/Mocha.Utilities.csproj" />
<Project Path="Mocha/src/Mocha.Transport.RabbitMQ/Mocha.Transport.RabbitMQ.csproj" />
<Project Path="Mocha/src/Mocha/Mocha.csproj" />
</Folder>
Expand Down
90 changes: 90 additions & 0 deletions src/Mocha/Mocha.sln
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,18 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Demo.ServiceDefaults", "src
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Demo.Contracts", "src\Demo\Demo.Contracts\Demo.Contracts.csproj", "{58C302B9-4E15-447B-ACE3-867813189848}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mocha.Mediator", "src\Mocha.Mediator\Mocha.Mediator.csproj", "{04AEA85E-50C1-46A6-9346-D3C02046A013}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mocha.Analyzers", "src\Mocha.Analyzers\Mocha.Analyzers.csproj", "{F1866F0C-7638-4DEB-AF64-46189F727FA2}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mocha.Analyzers.Tests", "test\Mocha.Analyzers.Tests\Mocha.Analyzers.Tests.csproj", "{C779F845-2F89-47C2-B993-1D2A1652C7FF}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mocha.EntityFrameworkCore.Tests", "test\Mocha.EntityFrameworkCore.Tests\Mocha.EntityFrameworkCore.Tests.csproj", "{EBB56CB0-71DA-48A5-BB8D-26870E500467}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mocha.Mediator.Abstractions", "src\Mocha.Mediator.Abstractions\Mocha.Mediator.Abstractions.csproj", "{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mocha.Utilities", "src\Mocha.Utilities\Mocha.Utilities.csproj", "{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Expand Down Expand Up @@ -355,6 +367,78 @@ Global
{58C302B9-4E15-447B-ACE3-867813189848}.Release|x64.Build.0 = Release|Any CPU
{58C302B9-4E15-447B-ACE3-867813189848}.Release|x86.ActiveCfg = Release|Any CPU
{58C302B9-4E15-447B-ACE3-867813189848}.Release|x86.Build.0 = Release|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Debug|Any CPU.Build.0 = Debug|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Debug|x64.ActiveCfg = Debug|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Debug|x64.Build.0 = Debug|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Debug|x86.ActiveCfg = Debug|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Debug|x86.Build.0 = Debug|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Release|Any CPU.ActiveCfg = Release|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Release|Any CPU.Build.0 = Release|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Release|x64.ActiveCfg = Release|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Release|x64.Build.0 = Release|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Release|x86.ActiveCfg = Release|Any CPU
{04AEA85E-50C1-46A6-9346-D3C02046A013}.Release|x86.Build.0 = Release|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Debug|Any CPU.Build.0 = Debug|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Debug|x64.ActiveCfg = Debug|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Debug|x64.Build.0 = Debug|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Debug|x86.ActiveCfg = Debug|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Debug|x86.Build.0 = Debug|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Release|Any CPU.ActiveCfg = Release|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Release|Any CPU.Build.0 = Release|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Release|x64.ActiveCfg = Release|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Release|x64.Build.0 = Release|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Release|x86.ActiveCfg = Release|Any CPU
{F1866F0C-7638-4DEB-AF64-46189F727FA2}.Release|x86.Build.0 = Release|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Debug|Any CPU.Build.0 = Debug|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Debug|x64.ActiveCfg = Debug|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Debug|x64.Build.0 = Debug|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Debug|x86.ActiveCfg = Debug|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Debug|x86.Build.0 = Debug|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Release|Any CPU.ActiveCfg = Release|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Release|Any CPU.Build.0 = Release|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Release|x64.ActiveCfg = Release|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Release|x64.Build.0 = Release|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Release|x86.ActiveCfg = Release|Any CPU
{C779F845-2F89-47C2-B993-1D2A1652C7FF}.Release|x86.Build.0 = Release|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Debug|Any CPU.Build.0 = Debug|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Debug|x64.ActiveCfg = Debug|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Debug|x64.Build.0 = Debug|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Debug|x86.ActiveCfg = Debug|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Debug|x86.Build.0 = Debug|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Release|Any CPU.ActiveCfg = Release|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Release|Any CPU.Build.0 = Release|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Release|x64.ActiveCfg = Release|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Release|x64.Build.0 = Release|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Release|x86.ActiveCfg = Release|Any CPU
{EBB56CB0-71DA-48A5-BB8D-26870E500467}.Release|x86.Build.0 = Release|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Debug|Any CPU.Build.0 = Debug|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Debug|x64.ActiveCfg = Debug|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Debug|x64.Build.0 = Debug|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Debug|x86.ActiveCfg = Debug|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Debug|x86.Build.0 = Debug|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Release|Any CPU.ActiveCfg = Release|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Release|Any CPU.Build.0 = Release|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Release|x64.ActiveCfg = Release|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Release|x64.Build.0 = Release|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Release|x86.ActiveCfg = Release|Any CPU
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3}.Release|x86.Build.0 = Release|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Debug|Any CPU.Build.0 = Debug|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Debug|x64.ActiveCfg = Debug|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Debug|x64.Build.0 = Debug|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Debug|x86.ActiveCfg = Debug|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Debug|x86.Build.0 = Debug|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Release|Any CPU.ActiveCfg = Release|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Release|Any CPU.Build.0 = Release|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Release|x64.ActiveCfg = Release|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Release|x64.Build.0 = Release|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Release|x86.ActiveCfg = Release|Any CPU
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E}.Release|x86.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
Expand Down Expand Up @@ -382,5 +466,11 @@ Global
{105A06D4-58C3-4A37-A590-C766D313AC8F} = {FB64595D-7A02-F2D4-9C1E-6F343453585F}
{046A5F8B-AF61-4C9C-A2E7-F965A3DF3AF6} = {FB64595D-7A02-F2D4-9C1E-6F343453585F}
{58C302B9-4E15-447B-ACE3-867813189848} = {FB64595D-7A02-F2D4-9C1E-6F343453585F}
{04AEA85E-50C1-46A6-9346-D3C02046A013} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
{F1866F0C-7638-4DEB-AF64-46189F727FA2} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
{C779F845-2F89-47C2-B993-1D2A1652C7FF} = {0C88DD14-F956-CE84-757C-A364CCF449FC}
{EBB56CB0-71DA-48A5-BB8D-26870E500467} = {0C88DD14-F956-CE84-757C-A364CCF449FC}
{074FF3A5-43AE-416C-8A12-9AA56D4DC7A3} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
{7C34B5D2-CDEC-483B-BDF7-9B414D97835E} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
EndGlobalSection
EndGlobal
Original file line number Diff line number Diff line change
@@ -0,0 +1,68 @@
using Microsoft.Extensions.DependencyInjection;

#pragma warning disable CS1591

namespace Mocha.Mediator.Benchmarks.Messaging;

partial class ImmediateCommandHandler
{
public sealed partial class Handler : global::Immediate.Handlers.Shared.IHandler<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse>
{
private readonly global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.HandleBehavior _handleBehavior;

public Handler(
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.HandleBehavior handleBehavior
)
{
var handlerType = typeof(ImmediateCommandHandler);

_handleBehavior = handleBehavior;

}

public async global::System.Threading.Tasks.ValueTask<global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> HandleAsync(
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Command request,
global::System.Threading.CancellationToken cancellationToken = default
)
{
return await _handleBehavior
.HandleAsync(request, cancellationToken)
.ConfigureAwait(false);
}
}

[global::System.ComponentModel.EditorBrowsable(global::System.ComponentModel.EditorBrowsableState.Never)]
public sealed class HandleBehavior : global::Immediate.Handlers.Shared.Behavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse>
{

public HandleBehavior(
)
{
}

public override async global::System.Threading.Tasks.ValueTask<global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> HandleAsync(
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Command request,
global::System.Threading.CancellationToken cancellationToken
)
{
return await global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler
.HandleAsync(
request
, cancellationToken
)
.ConfigureAwait(false);
}
}

[global::System.ComponentModel.EditorBrowsable(global::System.ComponentModel.EditorBrowsableState.Never)]
public static IServiceCollection AddHandlers(
IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Scoped
)
{
services.Add(new(typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Handler), typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Handler), lifetime));
services.Add(new(typeof(global::Immediate.Handlers.Shared.IHandler<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse>), typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.Handler), lifetime));
services.Add(new(typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.HandleBehavior), typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateCommandHandler.HandleBehavior), lifetime));
return services;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,86 @@
using Microsoft.Extensions.DependencyInjection;

#pragma warning disable CS1591

namespace Mocha.Mediator.Benchmarks.Messaging;

partial class ImmediateFullPipelineCommandHandler
{
public sealed partial class Handler : global::Immediate.Handlers.Shared.IHandler<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse>
{
private readonly global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.HandleBehavior _handleBehavior;
private readonly global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelinePostBehavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> _immediateFullPipelinePostBehavior;
private readonly global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineMainBehavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> _immediateFullPipelineMainBehavior;
private readonly global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelinePreBehavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> _immediateFullPipelinePreBehavior;

public Handler(
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.HandleBehavior handleBehavior,
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelinePostBehavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> immediateFullPipelinePostBehavior,
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineMainBehavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> immediateFullPipelineMainBehavior,
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelinePreBehavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> immediateFullPipelinePreBehavior
)
{
var handlerType = typeof(ImmediateFullPipelineCommandHandler);

_handleBehavior = handleBehavior;

_immediateFullPipelinePreBehavior = immediateFullPipelinePreBehavior;
_immediateFullPipelinePreBehavior.HandlerType = handlerType;

_immediateFullPipelineMainBehavior = immediateFullPipelineMainBehavior;
_immediateFullPipelineMainBehavior.HandlerType = handlerType;

_immediateFullPipelinePostBehavior = immediateFullPipelinePostBehavior;
_immediateFullPipelinePostBehavior.HandlerType = handlerType;

_immediateFullPipelinePostBehavior.SetInnerHandler(_handleBehavior);
_immediateFullPipelineMainBehavior.SetInnerHandler(_immediateFullPipelinePostBehavior);
_immediateFullPipelinePreBehavior.SetInnerHandler(_immediateFullPipelineMainBehavior);
}

public async global::System.Threading.Tasks.ValueTask<global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> HandleAsync(
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command request,
global::System.Threading.CancellationToken cancellationToken = default
)
{
return await _immediateFullPipelinePreBehavior
.HandleAsync(request, cancellationToken)
.ConfigureAwait(false);
}
}

[global::System.ComponentModel.EditorBrowsable(global::System.ComponentModel.EditorBrowsableState.Never)]
public sealed class HandleBehavior : global::Immediate.Handlers.Shared.Behavior<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse>
{

public HandleBehavior(
)
{
}

public override async global::System.Threading.Tasks.ValueTask<global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse> HandleAsync(
global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command request,
global::System.Threading.CancellationToken cancellationToken
)
{
return await global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler
.HandleAsync(
request
, cancellationToken
)
.ConfigureAwait(false);
}
}

[global::System.ComponentModel.EditorBrowsable(global::System.ComponentModel.EditorBrowsableState.Never)]
public static IServiceCollection AddHandlers(
IServiceCollection services,
ServiceLifetime lifetime = ServiceLifetime.Scoped
)
{
services.Add(new(typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Handler), typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Handler), lifetime));
services.Add(new(typeof(global::Immediate.Handlers.Shared.IHandler<global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Command, global::Mocha.Mediator.Benchmarks.Messaging.BenchmarkResponse>), typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.Handler), lifetime));
services.Add(new(typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.HandleBehavior), typeof(global::Mocha.Mediator.Benchmarks.Messaging.ImmediateFullPipelineCommandHandler.HandleBehavior), lifetime));
return services;
}
}
Loading
Loading