Skip to content

Commit

Permalink
Formatting fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
mburumaxwell committed Mar 8, 2024
1 parent 6514f63 commit 7b83d37
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public static PublishRequest SetAttributes(this PublishRequest request, EventCon
{
if (request is null) throw new ArgumentNullException(nameof(request));
static SNSAttribute creator(string v) => new() { DataType = "String", StringValue = v };

request.MessageAttributes.SetAttributes(creator, @event);
return request;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ public class InMemoryTransport(IServiceScopeFactory serviceScopeFactory,
IOptions<EventBusOptions> busOptionsAccessor,
IOptionsMonitor<InMemoryTransportOptions> optionsMonitor,
ILoggerFactory loggerFactory,
SequenceNumberGenerator sng)
SequenceNumberGenerator sng)
: EventBusTransport<InMemoryTransportOptions>(serviceScopeFactory, busOptionsAccessor, optionsMonitor, loggerFactory)
{
private readonly EventBusConcurrentDictionary<(Type, bool), InMemorySender> sendersCache = new();
Expand Down
8 changes: 4 additions & 4 deletions src/Tingle.EventBus/Transports/EventBusTransport.cs
Original file line number Diff line number Diff line change
Expand Up @@ -326,10 +326,10 @@ protected async Task<BinaryData> SerializeAsync<TEvent>(IServiceScope scope,
/// <returns>An <see cref="EventConsumeResult"/> representing the state of the action.</returns>
/// <param name="cancellationToken"></param>
protected async Task<EventConsumeResult> ConsumeAsync<TEvent, [DynamicallyAccessedMembers(TrimmingHelper.Consumer)] TConsumer>(EventRegistration registration,
EventConsumerRegistration ecr,
EventContext @event,
IServiceScope scope,
CancellationToken cancellationToken)
EventConsumerRegistration ecr,
EventContext @event,
IServiceScope scope,
CancellationToken cancellationToken)
where TConsumer : IEventConsumer
where TEvent : class
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,9 @@ namespace Microsoft.Extensions.DependencyInjection;
/// <param name="busOptionsAccessor">An <see cref="IOptions{TOptions}"/> for bus configuration.</param>
public abstract class EventBusTransportConfigureOptions<TOptions>(IEventBusConfigurationProvider configurationProvider,
IEnumerable<IEventBusConfigurator> configurators,
IOptions<EventBusOptions> busOptionsAccessor): IConfigureNamedOptions<TOptions>,
IPostConfigureOptions<TOptions>,
IValidateOptions<TOptions>
IOptions<EventBusOptions> busOptionsAccessor) : IConfigureNamedOptions<TOptions>,
IPostConfigureOptions<TOptions>,
IValidateOptions<TOptions>
where TOptions : EventBusTransportOptions
{
// Some hosts do not allow certain characters for ENV vars but we know they all support alphanumeric and underscore
Expand Down

0 comments on commit 7b83d37

Please sign in to comment.