Examples.EEVentBroker.WithSub (Anoma v0.31.0)

I contain examples of how the with_subscription block works.

Summary

I check that, when a process is subscribed to a given filter, that filter still exists after a with_subscription block that uses the same filter.

I nest two with_subscription blocks and assert that the middle one is subscribed to the outer topics as well.

I run a piece of code with a subscription. I assert that the messages sent within this block are sent to me.

I run a piece of code with a subscription to multiple filters. I assert that the messages sent within this block are sent to me.

@spec with_existing_subscription(struct()) :: struct()

I check that, when a process is subscribed to a given filter, that filter still exists after a with_subscription block that uses the same filter.

@spec with_nested_subscription([struct()]) :: [struct()]

I nest two with_subscription blocks and assert that the middle one is subscribed to the outer topics as well.

@spec with_subscription(struct()) :: struct()

I run a piece of code with a subscription. I assert that the messages sent within this block are sent to me.

@spec with_subscriptions([struct()]) :: [struct()]

I run a piece of code with a subscription to multiple filters. I assert that the messages sent within this block are sent to me.