quixos-templates/language-reader
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Export template source from be30143a326d5d7d7b0cbabea5bc5ac0301ef5b9:examples/local-first/workspaces/language-reader-studio

Browse Source
This commit is contained in:
Quixos Template Publisher
2000-01-01 00:00:00 +00:00
commit 17ef56d0cb
14 changed files with 776 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
events.qx
+21
View File
@@ -0,0 +1,21 @@
fragment {
import interface EventStream;
import interface EventHandler;
import interface EventSubscription;
import interface EventStreamRecord;
import interface EventSubscriptionRecord;
conform<value Payload> EventStreamRecord<Payload> as EventStream<Payload> 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<value Payload,value Parameters> EventSubscriptionRecord<Payload,Parameters> as EventSubscription<Payload,Parameters> 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;
}
}