     
     func registerOnEventLoop(initPipeline: (ChannelPipeline) throws ->()) {
         // Was not registered yet so do it now.
-        safeRegister(interested: InterestedEvent.Read)
+        safeRegister(interested: .Read)
         
         do {
             try initPipeline(pipeline)

    }
    
    func flush0() {
        if interestedEvent != InterestedEvent.Write && interestedEvent != InterestedEvent.All && !flushNow() {
            guard open else {
                return
            }
            // Could not flush all of the queued bytes, stop reading until we were able to do so
            if interestedEvent == InterestedEvent.Read {
                safeReregister(interested: InterestedEvent.Write)
            } else {
                safeReregister(interested: InterestedEvent.All)
            }
            pipeline.fireChannelWritabilityChanged(writable: false)
        }

    
    // Methods only used from within this class
    private func safeDeregister() {
        interestedEvent = .None
        do {
            try eventLoop.deregister(channel: self)
        } catch {
