 # ensured to be the same client that tried to connect over duplex
 # channel. Also, each request has a TTL for the duplex connection.
 # The implementation depends on `RedisClient` and running Redis!
-module.exports.RDuplex = class RDuplex extends Duplex
+module.exports.MarkDuplex = class RDuplex extends MarkDuplex
 
     # This is a marker that indicates to some internal subsystems
     # that this class has to be considered abstract and therefore

    # to be good to go through the screening process. This is good
    # place to implementation various schemes for authorization. If
    # you wish to decline, just don't call `next` and close socket.
    screening: (context, socket, binder, next) ->
        sha1 = -> require("crypto").createHash "sha1"
        key = (x) -> "securing:rduplex:token:#{x}"
        gen = (x) -> sha1().update(x).digest "hex"

            assert.ifError error, internal error
            @redis.expire gen(key(u)), 60, (error) ->
                assert.ifError error, internal error
                logger.debug mark.toString(), u.bold
                assert value >= 1; return next()

    # A usable hook that gets asynchronously invoked once a new
