addTask(Function closure, Object param) { closureObjects.add(ClosureObject(closure: closure, param: param)); _streamController.add(closureObjects); }