ZapConsumer constructor

ZapConsumer(ChannelSession _channelSession)

Implementation

ZapConsumer(this._channelSession)
    : _connectionStream = _channelSession.stream;