Sha256: 83b6567c060b11eb8de472c7e776102a68c2e2588b60f05252f431b6732013fb
Contents?: true
Size: 421 Bytes
Versions: 30
Compression:
Stored size: 421 Bytes
Contents
# frozen_string_literal: true require 'bundler/setup' require 'polyphony' socket = Polyphony::Net.tcp_connect('127.0.0.1', 1234) writer = spin do throttled_loop(1) do socket << "#{Time.now}\n" rescue StandardError nil end end reader = spin do puts 'received from echo server:' while (data = socket.readpartial(8192)) STDOUT << data end end sleep(5) [reader, writer].each(&:stop) socket.close
Version data entries
30 entries across 30 versions & 1 rubygems