summaryrefslogtreecommitdiff
path: root/nanomsg/feed.rb
diff options
context:
space:
mode:
authorPatrick Simianer <p@simianer.de>2015-05-13 20:32:08 +0200
committerPatrick Simianer <p@simianer.de>2015-05-13 20:32:08 +0200
commite76d0b1194c912f7329908d6f799eeccf9ab5456 (patch)
tree7f99524a31e86cb11e3661b97f3caa2c33230fca /nanomsg/feed.rb
parent717bead50c8b209dac3f6ac8cb2c081613850d26 (diff)
nanomsg
Diffstat (limited to 'nanomsg/feed.rb')
-rwxr-xr-xnanomsg/feed.rb22
1 files changed, 22 insertions, 0 deletions
diff --git a/nanomsg/feed.rb b/nanomsg/feed.rb
new file mode 100755
index 0000000..5ea9737
--- /dev/null
+++ b/nanomsg/feed.rb
@@ -0,0 +1,22 @@
+#!/usr/bin/env ruby
+
+require 'nanomsg'
+
+port = 60666
+sock = NanoMsg::PairSocket.new
+addr = "tcp://127.0.0.1:#{port}"
+#addr = "ipc:///tmp/network_decoder.ipc"
+sock.connect addr
+
+while true
+ line = STDIN.gets
+ if !line
+ sock.send 'shutdown'
+ break
+ end
+ puts "sending source '#{line.strip}'"
+ sock.send line.strip
+ sleep 1
+ puts "got translation: #{sock.recv}\n\n"
+end
+