lib/wamp/message_handler/result.rb in xconn-0.1.0 vs lib/wamp/message_handler/result.rb in xconn-0.1.1
- old
+ new
@@ -4,10 +4,14 @@
module MessageHandler
# Result
class Result < Base
def handle
validate_received_message
- stored_data.fetch(:handler).call(response)
+ if message.details[:progress]
+ store[store_key].fetch(:handler).call(response)
+ else
+ stored_data.fetch(:handler).call(response)
+ end
end
def response
Type::Result.new(args: message.args, kwargs: message.kwargs, details: message.details)
end