ASSERT (input == null); ASSERT (output == null);
    public void Run()     {        SetupOperator ();                // execute the stream here        while (true)        {            RunSinks ();            DrainChannels ();        }    }