From 32e60f4d9cef2b554506215f478ed35ef7ae9cfb Mon Sep 17 00:00:00 2001 From: Oliver Tomlinson Date: Thu, 27 Jul 2023 17:27:45 +0100 Subject: [PATCH] removed redundant code --- src/DeferredStateStore.cs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/DeferredStateStore.cs b/src/DeferredStateStore.cs index b9ee353..0b7f9eb 100644 --- a/src/DeferredStateStore.cs +++ b/src/DeferredStateStore.cs @@ -3,7 +3,7 @@ using Dapr.PluggableComponents.Components.StateStore; using Dapr.PluggableComponents.Components; -internal sealed record DeferredContext(MetadataRequest? MetadataRequest, IServiceProvider ServiceProvider, string InstanceId, TaskCompletionSource AllowInitToComplete); +internal sealed record DeferredContext(MetadataRequest? MetadataRequest, IServiceProvider ServiceProvider, string InstanceId); internal static class DaprPluggableComponentsServiceBuilderExtensions { @@ -21,7 +21,6 @@ internal sealed class DeferredStateStore : IStateStore, IPluggableComponentFe private T stateStore; private readonly IServiceProvider serviceProvider; private readonly string instanceId; - private readonly TaskCompletionSource allowInitToComplete; public DeferredStateStore(IServiceProvider serviceProvider, Func> componentFactory, string instanceId) { @@ -44,7 +43,7 @@ public Task DeleteAsync(StateStoreDeleteRequest request, CancellationToken cance public async Task InitAsync(MetadataRequest request, CancellationToken cancellationToken = default) { - this.stateStore = await this.componentFactory(new DeferredContext(request, serviceProvider, instanceId, allowInitToComplete)); + this.stateStore = await this.componentFactory(new DeferredContext(request, serviceProvider, instanceId)); return; }