[streaming] Operator invokable refactor