mock延迟响应的接口

        HttpServer server = getServer(8088)

        server.get(urlOnly("/aba")).response(delay(textRes("faun"), 5000))

        server.response("haha")

        MocoServer drive = run(server)


        waitForKey("fan")

        drive.stop()

/**
 * 延迟响应
 * @param handler
 * @param time 时间,单位ms,存在理论BUG,不能低于50ms
 * @return
 */
    static ResponseHandler delay(ResponseHandler handler, int time) {
        DelayHandler.newSeq(handler, time)
    }

/**
 * 延迟响应,默认1000ms
 * @param handler
 * @return
 */
    static ResponseHandler delay(ResponseHandler handler) {
        DelayHandler.newSeq(handler, 1000)
    }

package com.fun.moco.support


import com.github.dreamhead.moco.ResponseHandler
import com.github.dreamhead.moco.handler.AbstractResponseHandler
import com.github.dreamhead.moco.internal.SessionContext

import java.util.concurrent.TimeUnit

import static com.google.common.base.Preconditions.checkArgument

/**
 * 延迟响应API拓展ResponseHandler
 */
class DelayHandler extends AbstractResponseHandler {

    /**
     * 延迟时间
     */
    private final int time

    private final ResponseHandler handler

    private DelayHandler(ResponseHandler handler, int time) {
        this.time = time
        this.handler = handler
    }

    public static ResponseHandler newSeq(final ResponseHandler handler, int time) {
        checkArgument(handler != null, "responsehandler 不能为空!");
        return new DelayHandler(handler, time);
    }

/**
 *
 * @param context
 */
    @Override
    void writeToResponse(SessionContext context) {
        com.github.dreamhead.moco.util.Idles.idle(time, TimeUnit.MILLISECONDS)
        handler.writeToResponse(context)
    }

}