Sha256: 365d76946d1536df0f92a7400c2ef910b8c32e9a585bdb524c6178c0ad1a61f1

Contents?: true

Size: 922 Bytes

Versions: 6

Compression:

Stored size: 922 Bytes

Contents

require "spec_helper"

describe Rdkafka::Consumer::Partition do
  subject { Rdkafka::Consumer::Partition.new(1, 100) }

  it "should have a partition" do
    expect(subject.partition).to eq 1
  end

  it "should have an offset" do
    expect(subject.offset).to eq 100
  end

  describe "#to_s" do
    it "should return a human readable representation" do
      expect(subject.to_s).to eq "<Partition 1 with offset 100>"
    end
  end

  describe "#inspect" do
    it "should return a human readable representation" do
      expect(subject.to_s).to eq "<Partition 1 with offset 100>"
    end
  end

  describe "#==" do
    it "should equal another partition with the same content" do
      expect(subject).to eq Rdkafka::Consumer::Partition.new(1, 100)
    end

    it "should not equal another partition with different content" do
      expect(subject).not_to eq Rdkafka::Consumer::Partition.new(2, 101)
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
rdkafka-0.3.5 spec/rdkafka/consumer/partition_spec.rb
rdkafka-0.3.4 spec/rdkafka/consumer/partition_spec.rb
rdkafka-0.3.3 spec/rdkafka/consumer/partition_spec.rb
rdkafka-0.3.2 spec/rdkafka/consumer/partition_spec.rb
rdkafka-0.3.1 spec/rdkafka/consumer/partition_spec.rb
rdkafka-0.3.0 spec/rdkafka/consumer/partition_spec.rb