Dreamine.FullKit.Tests.Communication.ResilientTransportStateTests 클래스 참조

더 자세히 ...

클래스
class	ControllableTransport

Public 멤버 함수
async Task	StateChanged_NotFiredWithDuplicateState_UnderConcurrentNotify ()
async Task	DisposeAsync_IsIdempotent_UnderConcurrentCalls ()
async Task	SendAsync_QueuesMessageWhenDisconnected_WithQueuePolicy ()

상세한 설명

Resilient Transport State Tests 기능과 관련 상태를 캡슐화합니다.

ResilientTransportStateTests.cs 파일의 17 번째 라인에서 정의되었습니다.

멤버 함수 문서화

DisposeAsync_IsIdempotent_UnderConcurrentCalls()

async Task Dreamine.FullKit.Tests.Communication.ResilientTransportStateTests.DisposeAsync_IsIdempotent_UnderConcurrentCalls ( )

inline

이 인스턴스가 소유한 리소스를 해제합니다.

반환값

Dispose Async Is Idempotent Under Concurrent Calls 작업에서 생성한 Task 결과입니다.

ResilientTransportStateTests.cs 파일의 74 번째 라인에서 정의되었습니다.

    {
        var inner = new ControllableTransport();
        var policy = new ReconnectPolicy { Enabled = false };
        var transport = new ResilientMessageTransport(inner, policy);
 
        // Fire multiple concurrent DisposeAsync calls — only the first should take effect.
        var tasks = Enumerable.Range(0, 8)
            .Select(_ => transport.DisposeAsync().AsTask())
            .ToArray();
 
        await Task.WhenAll(tasks);
 
        // Inner transport should have been disposed exactly once.
        Assert.Equal(1, inner.DisposeCount);
    }

SendAsync_QueuesMessageWhenDisconnected_WithQueuePolicy()

async Task Dreamine.FullKit.Tests.Communication.ResilientTransportStateTests.SendAsync_QueuesMessageWhenDisconnected_WithQueuePolicy ( )

inline

Send Async Queues Message When Disconnected With Queue Policy 작업을 수행합니다.

반환값

Send Async Queues Message When Disconnected With Queue Policy 작업에서 생성한 Task 결과입니다.

ResilientTransportStateTests.cs 파일의 108 번째 라인에서 정의되었습니다.

    {
        var inner = new ControllableTransport();
        var policy = new ReconnectPolicy { Enabled = false };
        var queueOptions = new OutboundQueueOptions
        {
            DisconnectedSendPolicy = DisconnectedSendPolicy.Queue
        };
        await using var transport = new ResilientMessageTransport(inner, policy, queueOptions);
 
        var msg = new MessageEnvelope { Route = "test.route", Name = "hello" };
        await transport.SendAsync(msg);
 
        Assert.Equal(1, transport.QueuedMessageCount);
    }

StateChanged_NotFiredWithDuplicateState_UnderConcurrentNotify()

async Task Dreamine.FullKit.Tests.Communication.ResilientTransportStateTests.StateChanged_NotFiredWithDuplicateState_UnderConcurrentNotify ( )

inline

State Changed Not Fired With Duplicate State Under Concurrent Notify 작업을 수행합니다.

반환값

State Changed Not Fired With Duplicate State Under Concurrent Notify 작업에서 생성한 Task 결과입니다.

ResilientTransportStateTests.cs 파일의 36 번째 라인에서 정의되었습니다.

    {
        var inner = new ControllableTransport();
        var policy = new ReconnectPolicy { Enabled = false };
        await using var transport = new ResilientMessageTransport(inner, policy);
 
        var states = new System.Collections.Concurrent.ConcurrentBag<ConnectionState>();
        transport.StateChanged += (_, s) => states.Add(s);
 
        // Trigger connect so state transitions to Connected, then disconnect.
        await transport.ConnectAsync();
        await transport.DisconnectAsync();
 
        // All observed transitions must be real changes (no duplicate consecutive states).
        var list = states.ToArray();
        for (int i = 1; i < list.Length; i++)
        {
            Assert.NotEqual(list[i - 1], list[i]);
        }
    }

---

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

• ResilientTransportStateTests.cs