Contents

# !SLIDE :capture_code_output true
# Bi-directional ZMQ service.

require 'example_helper'
require 'asir/transport/zmq'
begin
  zmq = ASIR::Transport::Zmq.new(:port => 31920,
                                 :encoder => ASIR::Coder::Marshal.new,
                                 :one_way => false)
  server_process do
    zmq.prepare_server!
    zmq.run_server!
  end
  UnsafeService.asir.transport = t = zmq
  pr UnsafeService.asir.do_it(":ok")
rescue ::Exception => err
  $stderr.puts "### #{$$}: ERROR: #{err.inspect}\n  #{err.backtrace * "\n  "}"
  raise
ensure
  zmq.close rescue nil; sleep 1; server_kill
end

# !SLIDE END
# EXPECT: : client process
# EXPECT: : server process
# EXPECT: UnsafeService.do_it => :ok
# EXPECT: : pr: :ok
# EXPECT!: ERROR

Version data entries

9 entries across 9 versions & 2 rubygems

Version	Path
asir_zmq-1.2.0	example/ex02.rb
asir_zmq-1.1.1	example/ex02.rb
asir_zmq-1.1.0	example/ex02.rb
asir-1.0.8	example/ex21.rb
asir-1.0.7	example/ex21.rb
asir-1.0.6	example/ex21.rb
asir-1.0.5	example/ex21.rb
asir-1.0.4	example/ex21.rb
asir-1.0.1	example/ex21.rb