fragment { import interface EventStream; import interface EventHandler; import interface EventSubscription; import interface EventStreamRecord; import interface EventSubscriptionRecord; conform EventStreamRecord as EventStream id "events:standard-stream" { private state Entries id "events:entries" on Self : Payload policy journal {"maxEntries":128,"maxBytes":1048576,"maxPublicationBytes":262144,"maxProtectedSubscriptions":32}; bind publish.call to journal Entries.publish; bind head.get to journal Entries.head; bind readPage.call to journal Entries.readPage; } conform EventSubscriptionRecord as EventSubscription id "events:standard-subscription" { private state Delivery id "events:delivery" on Self : Parameters policy subscription(Payload); bind attach.call to subscription Delivery.attach; bind status.get to subscription Delivery.status; bind pause.call to subscription Delivery.pause; bind resume.call to subscription Delivery.resume; bind retire.call to subscription Delivery.retire; } }