StreamController<ChannelSessionMessage<T>> input
read / write