Sha256: ebed3b90a0c18f88503800542dcbe055f42053bdf11e9d2f8e67b8eb75da4b4c

Contents?: true

Size: 425 Bytes

Versions: 6

Compression:

Stored size: 425 Bytes

Contents

require_relative './service'

# QB STDIO Service to proxy interactive user input from the main process
# to modules.
class QB::IPC::STDIO::Server::InService < QB::IPC::STDIO::Server::Service
  def initialize name:, socket_dir:, src:
    super name: name, socket_dir: socket_dir
    @src = src
  end
  
  def work_in_thread
    while (line = @src.gets) do
      @socket.puts line
    end
    
    close!
  end
end # InService

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
qb-0.4.5 lib/qb/ipc/stdio/server/in_service.rb
qb-0.4.4 lib/qb/ipc/stdio/server/in_service.rb
qb-0.4.3 lib/qb/ipc/stdio/server/in_service.rb
qb-0.4.2 lib/qb/ipc/stdio/server/in_service.rb
qb-0.4.1 lib/qb/ipc/stdio/server/in_service.rb
qb-0.4.0 lib/qb/ipc/stdio/server/in_service.rb