ProjectionsSchemaObject
@parallelStreamProcessing
Use the @parallelStreamProcessing directive to allow parallel processing of events of different streams.
The use of this directive can have a significant impact on the performance of the projection.
Example
type User @upsertOn(...) @parallelStreamProcessing {
// ...
}In this case, the User projection will allow parallel processing of events of different streams.
Possible Inconsistencies
It's strongly recommended not to use this directive if events of different streams update data that is identified by the same identifier. This could lead to inconsistencies in the projection.