Examples.EEventBroker.Subscribe (Anoma v0.31.0)

I define examples on how to susbcribe to topics in the event broker.

Summary

Functions

assert_subscription(filter)

I assert that the current process is subscribed to the given filter.

refute_subscription(filters)

Given a list of filters, I make sure that the current process is not subscribed to them.

subscribe_to_filter(filter \\ %EFilter.AcceptAll{})

I subscribe using the Trivial filter and assert that I receive any events sent on the message broker.

subscribe_to_multiple_filters(filters \\ [%{__struct__: Examples.EEVentBroker.EFilter.AcceptAll}, %{__struct__: Examples.EEVentBroker.EFilter.Error}])

I subscribe to multiple filters and assert that I receive the events that are allowed by those filters.

unsubscribe_from_filter(filter \\ %EFilter.AcceptAll{})

I unsubscribe a process from a filter and verify that it is unsubscribed.

unsubscribe_on_down()

I subscribe a process to events, and check whether the registry cleans up its subscriptions when it goes offline.

Functions

assert_subscription(filter)

@spec assert_subscription([struct()] | struct()) :: [struct()] | struct()

I assert that the current process is subscribed to the given filter.

refute_subscription(filters)

@spec refute_subscription([struct()] | struct()) :: [struct()] | struct()

@spec refute_subscription(struct()) :: struct()

Given a list of filters, I make sure that the current process is not subscribed to them.

subscribe_to_filter(filter \\ %EFilter.AcceptAll{})

@spec subscribe_to_filter(struct()) :: {:received, any()}

I subscribe using the Trivial filter and assert that I receive any events sent on the message broker.

subscribe_to_multiple_filters(filters \\ [%{struct: Examples.EEVentBroker.EFilter.AcceptAll}, %{struct: Examples.EEVentBroker.EFilter.Error}])

@spec subscribe_to_multiple_filters([struct()]) :: {:received, any()}

I subscribe to multiple filters and assert that I receive the events that are allowed by those filters.

unsubscribe_from_filter(filter \\ %EFilter.AcceptAll{})

@spec unsubscribe_from_filter(struct()) :: {:received, any()}

I unsubscribe a process from a filter and verify that it is unsubscribed.

unsubscribe_on_down()

I subscribe a process to events, and check whether the registry cleans up its subscriptions when it goes offline.