Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket 클래스 참조

더 자세히 ...

Public 멤버 함수
bool	TryAdd (Subscription subscription)
Subscription[]	CreateSnapshot ()
void	Remove (Subscription subscription)
bool	TryCloseIfEmpty ()

Private 속성
readonly List< Subscription >	_subscriptions = new()
bool	_closed

상세한 설명

한 메시지 형식의 구독 컬렉션과 닫힘 상태를 잠금으로 보호합니다.

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

멤버 함수 문서화

CreateSnapshot()

Subscription[] Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket.CreateSnapshot ( )

inline

현재 구독 배열의 스레드 안전 스냅숏을 만듭니다.

반환값

현재 구독의 복사본입니다.

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

            {
                lock (_subscriptions)
                {
                    return _subscriptions.ToArray();
                }
            }

다음을 참조함 : _subscriptions.

Remove()

void Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket.Remove ( Subscription subscription )

inline

버킷에서 지정한 구독을 제거합니다.

매개변수

subscription

제거할 구독입니다.

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

            {
                lock (_subscriptions)
                {
                    _subscriptions.Remove(subscription);
                }
            }

다음을 참조함 : _subscriptions.

TryAdd()

bool Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket.TryAdd ( Subscription subscription )

inline

버킷이 열려 있으면 구독을 추가합니다.

매개변수

subscription

추가할 구독입니다.

반환값

추가했으면 true, 버킷이 닫혔으면 false입니다.

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

            {
                lock (_subscriptions)
                {
                    if (_closed)
                    {
                        return false;
                    }
 
                    _subscriptions.Add(subscription);
                    return true;
                }
            }

다음을 참조함 : _closed, _subscriptions.

다음에 의해서 참조됨 : Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.Subscribe< TMessage >().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

TryCloseIfEmpty()

bool Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket.TryCloseIfEmpty ( )

inline

구독이 없으면 버킷을 닫아 더 이상 추가되지 않게 합니다.

반환값

빈 버킷을 닫았으면 true, 아직 구독이 있으면 false입니다.

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

            {
                lock (_subscriptions)
                {
                    if (_subscriptions.Count != 0)
                    {
                        return false;
                    }
 
                    _closed = true;
                    return true;
                }
            }

다음을 참조함 : _closed, _subscriptions.

멤버 데이터 문서화

_closed

bool Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket._closed

private

closed 값을 보관합니다.

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

다음에 의해서 참조됨 : TryAdd(), TryCloseIfEmpty().

_subscriptions

readonly List<Subscription> Dreamine.Hybrid.Messaging.InMemoryHybridMessageBus.SubscriptionBucket._subscriptions = new()

private

subscriptions 값을 보관합니다.

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

다음에 의해서 참조됨 : CreateSnapshot(), Remove(), TryAdd(), TryCloseIfEmpty().

---

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

• InMemoryHybridMessageBus.cs