Class: Protocol::HTTP::Body::Rewindable

Inherits:
Wrapper show all
Defined in:
lib/protocol/http/body/rewindable.rb

Overview

A body which buffers all it’s contents as it is read.

As the body is buffered in memory, you may want to ensure your server has sufficient (virtual) memory available to buffer the entire body.

Instance Attribute Summary

Attributes inherited from Wrapper

#body

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Wrapper

#The wrapped body.=, #as_json, #close, #discard, #length, #to_json

Methods inherited from Readable

#as_json, #call, #close, #discard, #each, #finish, #join, #length, #stream?, #to_json

Constructor Details

#initialize(body) ⇒ Rewindable

Initialize the body with the given body.



32
33
34
35
36
37
 
# File 'lib/protocol/http/body/rewindable.rb', line 32

def initialize(body)
	super(body)
	
	@chunks = []
	@index = 0
end

Class Method Details

.wrap(message) ⇒ Object

Wrap the given message body in a rewindable body, if it is not already rewindable.



19
20
21
22
23
24
25
26
27
 
# File 'lib/protocol/http/body/rewindable.rb', line 19

def self.wrap(message)
	if body = message.body
		if body.rewindable?
			body
		else
			message.body = self.new(body)
		end
	end
end

Instance Method Details

#buffered ⇒ Object

A rewindable body wraps some other body. Convert it to a buffered body. The buffered body will share the same chunks as the rewindable body.



52
53
54
 
# File 'lib/protocol/http/body/rewindable.rb', line 52

def buffered
	Buffered.new(@chunks)
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


40
41
42
 
# File 'lib/protocol/http/body/rewindable.rb', line 40

def empty?
	(@index >= @chunks.size) && super
end

#inspect ⇒ Object

Inspect the rewindable body.



87
88
89
 
# File 'lib/protocol/http/body/rewindable.rb', line 87

def inspect
	"\#<#{self.class} #{@index}/#{@chunks.size} chunks read>"
end

#read ⇒ Object

Read the next available chunk. This may return a buffered chunk if the stream has been rewound, or a chunk from the underlying stream, if available.



59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/protocol/http/body/rewindable.rb', line 59

def read
	if @index < @chunks.size
		chunk = @chunks[@index]
		@index += 1
	else
		if chunk = super
			@chunks << -chunk
			@index += 1
		end
	end
	
	# We dup them on the way out, so that if someone modifies the string, it won't modify the rewindability.
	return chunk
end

#ready? ⇒ Boolean

Returns:

  • (Boolean) 


45
46
47
 
# File 'lib/protocol/http/body/rewindable.rb', line 45

def ready?
	(@index < @chunks.size) || super
end

#rewind ⇒ Object

Rewind the stream to the beginning.



75
76
77
 
# File 'lib/protocol/http/body/rewindable.rb', line 75

def rewind
	@index = 0
end

#rewindable? ⇒ Boolean

Returns:

  • (Boolean) 


80
81
82
 
# File 'lib/protocol/http/body/rewindable.rb', line 80

def rewindable?
	true
end