Как отличить операторы, выполняющие промежуточные действия, от тех, которые завершают поток выполнения в потоковых данных?