body.rb in async-http-cache-0.3.0

- old
+ new

@@ -19,11 +19,11 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 # THE SOFTWARE.
 
 require 'protocol/http/body/rewindable'
-require 'protocol/http/body/streamable'
+require 'protocol/http/body/completable'
 require 'protocol/http/body/digestable'
 
 module Async
 	module HTTP
 		module Cache
@@ -49,10 +49,10 @@
 								# Ensure the etag is listed as a trailer:
 								response.headers.add(TRAILERS, ETAG)
 							end
 							
 							# Wrap the response with the callback:
-							::Protocol::HTTP::Body::Streamable.wrap(response) do |error|
+							::Protocol::HTTP::Body::Completable.wrap(response) do |error|
 								if error
 									Async.logger.error(self) {error}
 								else
 									yield response, rewindable.buffered
 								end