Class: FileFM::StreamingUploader::MultipartStream
- Inherits:
-
Object
- Object
- FileFM::StreamingUploader::MultipartStream
- Defined in:
- lib/filefm/streaming_uploader.rb
Instance Method Summary collapse
-
#initialize(parts, blk = nil) ⇒ MultipartStream
constructor
A new instance of MultipartStream.
- #read(how_much) ⇒ Object
- #size ⇒ Object
Constructor Details
#initialize(parts, blk = nil) ⇒ MultipartStream
Returns a new instance of MultipartStream.
145 146 147 148 149 150 151 152 153 |
# File 'lib/filefm/streaming_uploader.rb', line 145 def initialize(parts, blk = nil) @callback = nil if blk @callback = blk end @parts = parts @part_no = 0 @part_offset = 0 end |
Instance Method Details
#read(how_much) ⇒ Object
159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 |
# File 'lib/filefm/streaming_uploader.rb', line 159 def read(how_much) @callback.call(how_much) if @callback return nil if @part_no >= @parts.size how_much_current_part = @parts[@part_no].size - @part_offset how_much_current_part = if how_much_current_part > how_much how_much else how_much_current_part end how_much_next_part = how_much - how_much_current_part current_part = @parts[@part_no].read(@part_offset, how_much_current_part) # recurse into the next part if the current one was not large enough if how_much_next_part > 0 @part_no += 1 @part_offset = 0 next_part = read(how_much_next_part) current_part + if next_part next_part else '' end else @part_offset += how_much_current_part current_part end end |
#size ⇒ Object
155 156 157 |
# File 'lib/filefm/streaming_uploader.rb', line 155 def size @parts.inject(0) {|size, part| size + part.size} end |