Sha256: e491bd8a40ef5113fb55827c6cd8daf205040e66b28c6f800f4c6cc75e8ccd3b
Contents?: true
Size: 731 Bytes
Versions: 2
Compression:
Stored size: 731 Bytes
Contents
# frozen_string_literal: true require 'kontena-websocket-client' require 'json' module CEX module Websocket class Client def listen_tickers(&_block) payload = { e: :subscribe, rooms: ['tickers'] } subscribe(payload) do |message| yield message end end private def subscribe(payload = {}, &_block) raise 'BlockMissingError' unless block_given? Kontena::Websocket::Client.connect(config_uri) do |client| client.send(payload.to_json) client.read do |message| yield message end client.close(1000) end end def config_uri CEX::Websocket.uri end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
cexio-websocket-0.1.1 | lib/cex/websocket/client.rb |
cexio-websocket-0.1.0 | lib/cex/websocket/client.rb |