Contents

module Elevate
  # A simple unidirectional stream of data with a single consumer.
  #
  # @api private
  class Channel
    def initialize(block)
      @target = block
    end

    # Pushes data to consumers immediately
    #
    # @return [void]
    #
    # @api private
    def <<(obj)
      @target.call(obj)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
elevate-0.7.0	lib/elevate/channel.rb