$eventMachine->watch(Stream::ofWriteModel() || Stream::ofService('service_name', 'stream-projection-name')) //Resolved to service event stream, if no stream-projection-name given
->with('projection-name', Projector::class)
//DocumentProjector::__invoke($prjState, DocumentReadModel $readModel, Message $event)
//StreamProjector::__invoke($prjState, StreamReadModel $readModel, Message $event)
->filterAggregateType('Aggregate\Type') //Optional
->filterEvents(array $listOfEventNames) //Optional
->storeDocumentsWithSchema(JsonSchema::object([...])); //JsonSchema of the stored read model documents
//->storeAsStream(); //Alternative to ->storeDocumentsWithSchema()