Contents

require 'spec_helper'
require 'hamster/experimental/mutable_set'

describe 'Tapping into with group identifier' do
  let(:deliverer) { Freddy.build(logger, config) }
  let(:responder1) { Freddy.build(logger, config) }
  let(:responder2) { Freddy.build(logger, config) }

  let(:destination)  { random_destination }

  after { [deliverer, responder1, responder2].each(&:close) }

  it 'receives a message once' do
    msg_counter = Hamster::MutableSet[]

    group_id = arbitrary_id
    responder1.tap_into(destination, group: group_id) { |_msg| msg_counter << 'r1' }
    responder2.tap_into(destination, group: group_id) { |_msg| msg_counter << 'r2' }
    deliverer.deliver(destination, {})

    default_sleep
    expect(msg_counter.count).to eq(1)
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
freddy-1.5.0	spec/integration/tap_into_with_group_spec.rb
freddy-1.4.2	spec/integration/tap_into_with_group_spec.rb