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

더 자세히 ...

Public 멤버 함수
async Task	PublishAsync_DispatchesToMatchingRouteWhenConnected ()
async Task	PublishAsync_ThrowsWhenDisconnected ()
async Task	DisposeAsync_ClearsSubscriptionsAndDisconnects ()

상세한 설명

In Memory Message Bus Tests 기능과 관련 상태를 캡슐화합니다.

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

멤버 함수 문서화

DisposeAsync_ClearsSubscriptionsAndDisconnects()

async Task Dreamine.FullKit.Tests.Communication.InMemoryMessageBusTests.DisposeAsync_ClearsSubscriptionsAndDisconnects ( )

inline

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

반환값

Dispose Async Clears Subscriptions And Disconnects 작업에서 생성한 Task 결과입니다.

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

    {
        var bus = new InMemoryMessageBus();
        var count = 0;
        await bus.SubscribeAsync("route", (_, _) =>
        {
            count++;
            return Task.CompletedTask;
        });
 
        await bus.ConnectAsync();
        await bus.DisposeAsync();
        await bus.ConnectAsync();
        await bus.PublishAsync(new MessageEnvelope { Route = "route" });
 
        Assert.Equal(0, count);
    }

PublishAsync_DispatchesToMatchingRouteWhenConnected()

async Task Dreamine.FullKit.Tests.Communication.InMemoryMessageBusTests.PublishAsync_DispatchesToMatchingRouteWhenConnected ( )

inline

Publish Async Dispatches To Matching Route When Connected 작업을 수행합니다.

반환값

Publish Async Dispatches To Matching Route When Connected 작업에서 생성한 Task 결과입니다.

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

    {
        var bus = new InMemoryMessageBus();
        var received = new List<string>();
        await bus.SubscribeAsync("route.a", (message, _) =>
        {
            received.Add(message.Name);
            return Task.CompletedTask;
        });
 
        await bus.ConnectAsync();
        await bus.PublishAsync(new MessageEnvelope { Route = "route.a", Name = "Ping" });
        await bus.PublishAsync(new MessageEnvelope { Route = "route.b", Name = "Ignored" });
 
        Assert.Equal(ConnectionState.Connected, bus.State);
        Assert.Equal(new[] { "Ping" }, received);
    }

PublishAsync_ThrowsWhenDisconnected()

async Task Dreamine.FullKit.Tests.Communication.InMemoryMessageBusTests.PublishAsync_ThrowsWhenDisconnected ( )

inline

Publish Async Throws When Disconnected 작업을 수행합니다.

반환값

Publish Async Throws When Disconnected 작업에서 생성한 Task 결과입니다.

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

    {
        var bus = new InMemoryMessageBus();
 
        await Assert.ThrowsAsync<InvalidOperationException>(
            () => bus.PublishAsync(new MessageEnvelope { Route = "route" }));
    }

---

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

• InMemoryMessageBusTests.cs