Class: Riak::Client::HTTPBackend::KeyStreamer

Inherits:

Object

• Object
• Riak::Client::HTTPBackend::KeyStreamer

Includes:

Util::Escape

Defined in:

lib/riak/client/http_backend/key_streamer.rb

Instance Method Summary

• #accept(chunk) ⇒ Object
• #initialize(block) ⇒ KeyStreamer constructor

  A new instance of KeyStreamer.

• #to_proc ⇒ Object

Methods included from Util::Escape

#escape, #maybe_escape, #maybe_unescape, #unescape

Constructor Details

#initialize(block) ⇒ KeyStreamer

Returns a new instance of KeyStreamer.

# File 'lib/riak/client/http_backend/key_streamer.rb', line 11

def initialize(block)
  @buffer = ""
  @block = block
end

Instance Method Details

#accept(chunk) ⇒ Object

# File 'lib/riak/client/http_backend/key_streamer.rb', line 16

def accept(chunk)
  @buffer << chunk
  consume
end

#to_proc ⇒ Object

# File 'lib/riak/client/http_backend/key_streamer.rb', line 21

def to_proc
  method(:accept).to_proc
end