spec.rb

require "unit_helper"
require "event_sourcing/event/bus/stream"

describe EventSourcing::Event::Bus::Stream do
  let(:bus_stream)   { EventSourcing::Event::Bus::Stream.new(store_stream, event_bus) }
  let(:store_stream) { instance_double("EventSourcing::Event::Store::Stream") }
  let(:event_bus)    { instance_double("EventSourcing::Event::Bus::Reference") }

  context "each" do
    before do
      # allow call to store_stream.each with block here
    end

    let(:enumerable) { double("Enumerable") }
    let(:block) { lambda {} }

    it "delegates to the store stream" do
      expect(bus_stream.each(&block)).to eq(enumerable)
    end

    it "is an enumerable" do
      expect(bus_stream).to be_a(Enumerable)
    end
  end
end

it "is an Enumerable" do
  expect(bus_stream).to be_a(Enumerable)
end

it "delegates `each` to the store" do
  received_block = nil
  store_stream = instance_double("StoreStream")
  allow(store_stream).to receive(:each) { |&b| received_block = b }
  some_action = lambda {}

  bus_stream.each(&some_action)

  expect(received_block).to be some_action
end

  context "each" do
    before do
      @received_block = nil
      allow(store_stream).to receive(:each) { |&b| @received_block = b }
      bus_stream.each(&block)
    end

    let(:block) { lambda {} }

    it "delegates to the store stream" do
      expect(@received_block).to be(block)
    end

    it "is an enumerable" do
      expect(bus_stream).to be_a(Enumerable)
    end
  end