Sha256: b9838b091afc085ecb7ee6e044bb4db9853510e43f1f75f76f5d0ee6b461af0b
Contents?: true
Size: 469 Bytes
Versions: 6
Compression:
Stored size: 469 Bytes
Contents
#!/usr/bin/env ruby
# ingest several data streams concurently forever
require_relative 'wendelin_test'
def runingest(stream_ref)
i = 0
while true
data_chunk = ", #{i} (#{stream_ref})"
#puts "ingest #{stream_ref}, #{data_chunk}"
ingest stream_ref, data_chunk
i = i + 1
sleep 0.1
end
end
t31 = Thread.new { runingest 'ABC-HELLO-01.cat' }
t32 = Thread.new { runingest 'ABC-HELLO-01.tac' }
t31.join # wait forever
Version data entries
6 entries across 6 versions & 1 rubygems