class Aws::Lambda::Client

def invoke_with_response_stream(params = {}, options = {}, &block)

Parameters:
  • params (Hash) -- ({})

Overloads:
  • invoke_with_response_stream(params = {})

Other tags:
    See: http://docs.aws.amazon.com/goto/WebAPI/lambda-2015-03-31/InvokeWithResponseStream - AWS API Documentation

Other tags:
    Example: Response structure -
    Example: Request syntax with placeholder values -
    Example: EventStream Operation Example -

Returns:
  • (Types::InvokeWithResponseStreamResponse) - Returns a {Seahorse::Client::Response response} object which responds to the following methods:

Options Hash: (**params)
  • :payload (String, StringIO, File) --
  • :qualifier (String) --
  • :client_context (String) --
  • :log_type (String) --
  • :invocation_type (String) --
  • :function_name (required, String) -- 
def invoke_with_response_stream(params = {}, options = {}, &block)
  params = params.dup
  event_stream_handler = case handler = params.delete(:event_stream_handler)
    when EventStreams::InvokeWithResponseStreamResponseEvent then handler
    when Proc then EventStreams::InvokeWithResponseStreamResponseEvent.new.tap(&handler)
    when nil then EventStreams::InvokeWithResponseStreamResponseEvent.new
    else
      msg = "expected :event_stream_handler to be a block or "\
            "instance of Aws::Lambda::EventStreams::InvokeWithResponseStreamResponseEvent"\
            ", got `#{handler.inspect}` instead"
      raise ArgumentError, msg
    end
  yield(event_stream_handler) if block_given?
  req = build_request(:invoke_with_response_stream, params)
  req.context[:event_stream_handler] = event_stream_handler
  req.handlers.add(Aws::Binary::DecodeHandler, priority: 95)
  req.send_request(options, &block)
end