Contents

module Goliath
  module Synchrony

    #
    # FIXME: generalize this to work with any deferrable
    module ResponseReceiver
      attr_accessor :env, :status, :headers, :body

      # Override this method in your middleware to perform any preprocessing
      # (launching a deferred request, perhaps)
      def pre_process
      end

      # Override this method in your middleware to perform any postprocessing.  This
      # will only be invoked when the deferrable and the response have been
      # received.
      #
      # @return [Array] array contains [status, headers, body]
      def post_process
        [status, headers, body]
      end

      # Invoked by the async_callback chain. Stores the [status, headers, body]
      # for post_process'ing
      def call shb
        return shb if shb.first == Goliath::Connection::AsyncResponse.first
        @status, @headers, @body = shb
        succeed if finished?
      end

      # Have we received a response?
      def response_received?
        !! @status
      end
    end

    class MultiReceiver < EM::Synchrony::Multi
      include ResponseReceiver

      # Create a new MultiReceiver
      # @param env [Goliath::Env] the current environment
      def initialize env
        @env = env
        super()
      end

      alias_method :enqueue, :add

      def successes
        responses[:callback]
      end

      def failures
        responses[:errback]
      end

      # Finished if we received a response and the multi request is finished
      def finished?
        super && response_received?
      end
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
goliath-0.9.2	lib/goliath/synchrony/response_receiver.rb