Skip to content

Commit

Permalink
Fix code error
Browse files Browse the repository at this point in the history
  • Loading branch information
Arkatufus authored and Aaronontheweb committed Jan 13, 2025
1 parent 6ffd304 commit 8073bec
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,6 @@ protected override void OnReceive(object message)
}
}

#endregion
private sealed class FakeRememberEntitiesProvider: IRememberEntitiesProvider
{
private readonly IActorRef _probe;
Expand Down Expand Up @@ -93,7 +92,7 @@ private class FakeShardStoreActor : ActorBase
private readonly string _shardId;
private readonly IActorRef _probe;

private FakeShardStoreActor(string shardId, IActorRef probe)
public FakeShardStoreActor(string shardId, IActorRef probe)
{
_shardId = shardId;
_probe = probe;
Expand All @@ -119,7 +118,7 @@ private class FakeCoordinatorStoreActor : ActorBase
{
public static Props Props() => Actor.Props.Create(() => new FakeCoordinatorStoreActor());

private FakeCoordinatorStoreActor()
public FakeCoordinatorStoreActor()
{
Context.System.EventStream.Publish(new CoordinatorStoreCreated(Context.Self));
}
Expand Down Expand Up @@ -158,6 +157,8 @@ private static Config GetConfig()
.WithFallback(ClusterSingleton.DefaultConfig());
}

#endregion

private readonly IActorRef _shard;
private IActorRef _store;

Expand Down Expand Up @@ -194,6 +195,8 @@ public WrappedShardBufferedMessageSpec(ITestOutputHelper output) : base(GetConfi
[Fact(DisplayName = "Message wrapped in ShardingEnvelope, buffered by Shard, must arrive in entity actor")]
public async Task WrappedMessageDelivery()
{
IgnoreMessages<ShardRegion.StartEntityAck>();

var continueMessage = await ExpectShardStartup();

// this message should be buffered
Expand Down

0 comments on commit 8073bec

Please sign in to comment.