Можно ли создать собственную операцию для обработки потоков данных в рамках существующей системы?