package Ġio . lib p 2 p . etc . util . netty Ċ Ċ import Ġio . netty . channel . Channel Ċ import Ġio . netty . channel . Default Channel Pipeline Ċ Ċ // ĠTODO Ġexperimental Ċ class ĠC aching Channel Pipeline ( channel : ĠChannel ) Ġ: ĠDefault Channel Pipeline ( channel ) Ġ{ ĊĊĠĠĠ Ġenum Ġclass ĠEventType Ġ{ ĠMessage , ĠException , ĠUser Event , ĠActive , ĠIn active Ġ} ĊĠĠĠ Ġclass ĠEvent ( val Ġtype : ĠEventType , Ġdata : ĠAny ?) ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Inbound Message ( msg : ĠAny ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Inbound Message ( msg ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Inbound Channel Read Complete () Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Inbound Channel Read Complete () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Inbound User Event Triggered ( evt : ĠAny ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Inbound User Event Triggered ( evt ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Inbound Exception ( cause : ĠThrowable ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Inbound Exception ( cause ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Channel Writ ability Changed () Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Channel Writ ability Changed () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Inbound Channel Active () Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Inbound Channel Active () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġon Unhandled Inbound Channel Inactive () Ġ{ ĊĠĠĠĠĠĠĠ Ġsuper . on Unhandled Inbound Channel Inactive () ĊĠĠĠ Ġ} Ċ }