Sha256: a3269f0526458f87c0a9d999f96d4a3f1eaec95a4aa6ffa36bb0851e1d2f8a4b
Contents?: true
Size: 493 Bytes
Versions: 6
Compression:
Stored size: 493 Bytes
Contents
require_relative './service'
# QB STDIO Service to proxy output from modules back to the main user
# process.
class QB::IPC::STDIO::Server::OutService < QB::IPC::STDIO::Server::Service
def initialize name:, socket_dir:, dest:
super name: name, socket_dir: socket_dir
@dest = dest
end
def work_in_thread
while (line = @socket.gets) do
logger.trace "received line",
line: line,
dest: @dest
@dest.puts line
end
end
end # InService
Version data entries
6 entries across 6 versions & 1 rubygems