Sha256: 768ce0f1eb103b7477dbdfe83595674e28fb998d7f75b8c41332cd293ef5f3e5

Contents?: true

Size: 294 Bytes

Versions: 37

Compression:

Stored size: 294 Bytes

Contents

module Pacer::Pipes
  class TypeFilterPipe < RubyPipe
    def initialize(type)
      super()
      @type = type
    end

    def processNextStart()
      while @starts.hasNext
        s = @starts.next
        return s if s.is_a? @type
      end
      raise EmptyPipe.instance
    end
  end
end

Version data entries

37 entries across 37 versions & 1 rubygems

Version Path
pacer-2.0.24-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.22-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.20-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.19-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.18-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.17-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.16-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.15-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.14-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.13-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.12-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.10-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.10.pre-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.8-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.6-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.4.pre-java lib/pacer/pipe/type_filter_pipe.rb
pacer-2.0.0.pre-java lib/pacer/pipe/type_filter_pipe.rb
pacer-1.6.0-java lib/pacer/pipe/type_filter_pipe.rb
pacer-1.5.4-java lib/pacer/pipe/type_filter_pipe.rb
pacer-1.5.3-java lib/pacer/pipe/type_filter_pipe.rb