Class: Wukong::Processor::Head

Inherits:

Filter

• Object
• Hanuman::Stage
• Wukong::Processor
• Filter
• Wukong::Processor::Head

Defined in:

lib/wukong/widget/filters.rb

Overview

Emit only the first n records.

See Also:

• Filter

Constant Summary

Constants inherited from Wukong::Processor

SerializerError

Instance Attribute Summary

• #count ⇒ Object

  The current record count.

Instance Method Summary

• #select?(record) ⇒ true, false

  Select a record only if we're below the maximum number of records.

• #setup ⇒ Object

  Initializes the record count to zero.

Methods inherited from Filter

#process, #reject?

Methods inherited from Wukong::Processor

configure, consumes, description, #expected_record_type, #expected_serialization, #finalize, #perform_action, #process, produces, #receive_action, #stop, valid_serializer?, validate_and_set_serialization

Methods included from Logging

included

Methods included from Hanuman::StageClassMethods

#builder, #label, #register, #set_builder

Instance Attribute Details

#count ⇒ Object

The current record count.

# File 'lib/wukong/widget/filters.rb', line 383

def count
  @count
end

Instance Method Details

#select?(record) ⇒ true, false

Select a record only if we're below the maximum number of records.

Parameters:

• record (Object)

Returns:

• (true, false)

# File 'lib/wukong/widget/filters.rb', line 395

def select?(record)
  keep = @count < n
  @count += 1
  keep
end

#setup ⇒ Object

Initializes the record count to zero.

# File 'lib/wukong/widget/filters.rb', line 386

def setup
  self.count = 0
end