Removed duplicate policy() method from Counters application in docs.
@@ -116,10 +116,6 @@ Now let's define an analytics application...
class Counters(ProcessApplication):
-
- def policy(self, domain_event, process_event):
- pass
-
@singledispatchmethod
def policy(self, domain_event, process_event):
"""Default policy"""
@@ -156,6 +152,7 @@ Single-threaded runner
from eventsourcing.system import SingleThreadedRunner
+
runner= SingleThreadedRunner(system)
runner.start()
worlds = runner.get(WorldsApplication)
@@ -198,6 +195,7 @@ Multi-threaded runner
from eventsourcing.system import MultiThreadedRunner
+
runner= MultiThreadedRunner(system)
runner.start()
worlds = runner.get(WorldsApplication)
