Sha256: b849778b998f1824b0917df9e02619fca97d66a974a75cf3198e5a862909a84b

Contents?: true

Size: 224 Bytes

Versions: 10

Compression:

Stored size: 224 Bytes

Contents

require_relative "../lib/nats/rpc"

servant = NATS::RPC::Servant.new
servant.serve! 'testing', queue: "e2e" do |params, subject|
  puts "got params: #{params.inspect} in subject: #{subject}"
  params["reverse"].reverse
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
nats-rpc-0.2.1 e2e/servant.rb
nats-rpc-0.2.0 e2e/servant.rb
nats-rpc-0.1.0 e2e/servant.rb
nats-rpc-0.0.7 e2e/servant.rb
nats-rpc-0.0.6 e2e/servant.rb
nats-rpc-0.0.5 e2e/servant.rb
nats-rpc-0.0.4 e2e/servant.rb
nats-rpc-0.0.3 e2e/servant.rb
nats-rpc-0.0.2 e2e/servant.rb
nats-rpc-0.0.1 e2e/servant.rb