Sha256: 83247d34b26b374e901127966af0fa884766c0fb7117834404583e1ca0a5e87e
Contents?: true
Size: 452 Bytes
Versions: 21
Compression:
Stored size: 452 Bytes
Contents
module Skylight
module Worker
class Embedded
def initialize(collector)
@collector = collector
end
def spawn
@collector.spawn
end
def shutdown
@collector.shutdown
end
def submit(msg)
decoder = Messages::ID_TO_KLASS.fetch(Messages::KLASS_TO_ID.fetch(msg.class))
msg = decoder.deserialize(msg.serialize)
@collector.submit(msg)
end
end
end
end
Version data entries
21 entries across 21 versions & 1 rubygems