Sha256: 6b88fe107ca88a0b44022b453aecb61152fca251c28b9d10b5313169388d2baf

Contents?: true

Size: 803 Bytes

Versions: 6

Compression:

Stored size: 803 Bytes

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