Writing a custom operator that involves Schedulers