It's an internal class used to implement the operators, that receives events and processes them.

If one sequence terminates with error, then all of the dependent sequences will terminate with error