hns


exports.app = function myAsyncApp(request){
  return function(responder){
    responder.init(200, {});
    var i = 0;
    var intervalId = setInterval(function(){
      responder.write("Every second another message");
      if(i++ == 10){
        responder.close();
        clearInterval(intervalId);
      }
    }, 1000);
  };
}

function middleware(app) {
  return function(request) {
    var response = app(request);
    if (typeof response === "function") {
      return function(responder) {
        // createResponderProxy is a utility function
        var proxy = createResponderProxy(responder);
        proxy.[init|write|close] = ...;
        response.then(proxy)
      };
    } else {
      // sync
    }
  }
}