Contents

require 'spec_helper'

describe Datapipes::Tube do
  describe 'composable' do
    let(:tube_a) do
      Class.new(Datapipes::Tube) do
        def run(data)
          data + 2
        end
      end.new
    end

    let(:tube_b) do
      Class.new(Datapipes::Tube) do
        def run(data)
          data * 3
        end
      end.new
    end

    let(:tube_c) do
      Class.new(Datapipes::Tube) do
        def run(data)
          data + 4
        end
      end.new
    end

    subject { tube_a >> tube_b >> tube_c }

    it 'composes' do
      expect(subject.run(4)).to eq 22
    end

    describe 'associative law' do
      let(:a) { (tube_a >> tube_b) >> tube_c }
      let(:b) { tube_a >> (tube_b >> tube_c) }

      it 'keeps' do
        expect(a.run(5)).to eq b.run(5)
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
datapipes-0.1.5	spec/tube_spec.rb
datapipes-0.1.4	spec/tube_spec.rb
datapipes-0.1.3	spec/tube_spec.rb
datapipes-0.1.2	spec/tube_spec.rb
datapipes-0.1.1	spec/tube_spec.rb
datapipes-0.1.0	spec/tube_spec.rb