diff --git a/lib/fog/aws/requests/kinesis/create_stream.rb b/lib/fog/aws/requests/kinesis/create_stream.rb index bfa2fb420..4ae3a8280 100644 --- a/lib/fog/aws/requests/kinesis/create_stream.rb +++ b/lib/fog/aws/requests/kinesis/create_stream.rb @@ -19,11 +19,10 @@ module Fog "StreamName" => options.delete("StreamName") }.reject{ |_,v| v.nil? } - response = request({ - 'X-Amz-Target' => "Kinesis_#{@version}.CreateStream", - :body => body, - }.merge(options)) - response + request({ + 'X-Amz-Target' => "Kinesis_#{@version}.CreateStream", + :body => body, + }.merge(options)) end end diff --git a/lib/fog/aws/requests/kinesis/delete_stream.rb b/lib/fog/aws/requests/kinesis/delete_stream.rb index 445afda92..9f315eda5 100644 --- a/lib/fog/aws/requests/kinesis/delete_stream.rb +++ b/lib/fog/aws/requests/kinesis/delete_stream.rb @@ -17,11 +17,10 @@ module Fog "StreamName" => options.delete("StreamName") }.reject{ |_,v| v.nil? } - response = request({ - 'X-Amz-Target' => "Kinesis_#{@version}.DeleteStream", - :body => body, - }.merge(options)) - response + request({ + 'X-Amz-Target' => "Kinesis_#{@version}.DeleteStream", + :body => body, + }.merge(options)) end end diff --git a/lib/fog/aws/requests/kinesis/merge_shards.rb b/lib/fog/aws/requests/kinesis/merge_shards.rb index 93ce8e60a..f49d62889 100644 --- a/lib/fog/aws/requests/kinesis/merge_shards.rb +++ b/lib/fog/aws/requests/kinesis/merge_shards.rb @@ -21,11 +21,10 @@ module Fog "StreamName" => options.delete("StreamName") }.reject{ |_,v| v.nil? } - response = request({ - 'X-Amz-Target' => "Kinesis_#{@version}.MergeShards", - :body => body, - }.merge(options)) - response + request({ + 'X-Amz-Target' => "Kinesis_#{@version}.MergeShards", + :body => body, + }.merge(options)) end end diff --git a/lib/fog/aws/requests/kinesis/split_shard.rb b/lib/fog/aws/requests/kinesis/split_shard.rb index 44dfc805b..bc58e79d5 100644 --- a/lib/fog/aws/requests/kinesis/split_shard.rb +++ b/lib/fog/aws/requests/kinesis/split_shard.rb @@ -21,11 +21,10 @@ module Fog "StreamName" => options.delete("StreamName") }.reject{ |_,v| v.nil? } - response = request({ - 'X-Amz-Target' => "Kinesis_#{@version}.SplitShard", - :body => body, - }.merge(options)) - response + request({ + 'X-Amz-Target' => "Kinesis_#{@version}.SplitShard", + :body => body, + }.merge(options)) end end