protected ReactorImpl(IO io, ReactorOptions options) throws IOException {
    collector = (CollectorImpl)Proton.collector();
    global = new IOHandler();
    handler = new BaseHandler();
    children = new HashSet<ReactorChild>();
    selectables = 0;
    timer = new Timer(collector);
    this.io = io;
    wakeup = this.io.pipe();
    mark();
    attachments = new RecordImpl();
    this.options = options;
}
 

public static Collector create() {
    return new CollectorImpl();
}
 

public Timer(Collector collector) {
    this.collector = (CollectorImpl)collector;
}