eventmachine

0熱

1答えて

イベントマシンで少し演奏していて、別のスレッドで実行されているコードがあります。彼のコールバックをメインスレッドに同期させたいので、 thread.post { fiber.resume(result) } ファイバーの親はスレッドですが、実行コンテキストは別のスレッドにあります。おかげで、

0熱

1答えて

Dashingがビューポート以外のウィジェットを更新するのを止める方法

Shopify/Dashingをベースにホームオートメーションダッシュボードをセットアップしました。 DashingはGridster.jsを使用して、私が持っている大量のウィジェットを&ページに割り当てます。ページはDashing.cycleDashboards（）で切り替わります。ウィジェットは、私が原因で、ダッシュボードが実行されている旧式のブラウザで複数のダッシュボードを作成しないことを選

0熱

2答えて

WebSocketとRedisの結果、pubsubやbrpopからの接続がハングアップする

WebSocket（WS）内でRedisサブスクリプションを発行しています。 WSが開いたら、私は要求をスレッド化し、次にRedisクライアントをインスタンス化します。オープンの中で、私はRedisのスレッドとサブスクリプションを発行します。予期しないWSクローズが発生するまで、これはすべて正常に動作します。その時点で、Redisサブスクリプションを実行しているスレッドはなくなりました。私が契約

2熱

1答えて

ループはEventmachine/faye websocketに入ります

これはサーバー側Webソケットクライアントです。私は、ループのユーザー入力を取得しようとしているし、サーバーにwebsocketメッセージとして送信します。基本的な動作が働いていて、サーバーにping/pongできます。しかし、WebSocketをon(:open)機能にループを配置するために働いていない：クライアント（抜粋）：正常に動作しているようだ require 'faye/websock

0熱

1答えて

ルビーのオープンファイバーの量を取得

rubyアプリケーションで現在開いているファイバーの量を取得するにはどうすればよいですか？私のアプリケーションは、並行処理のためにEventMachine Synchrony libを使用しています。グーグルでは、APIを返すAPIが見つかりませんでした。例えば私は、コードのこの部分がある場合： EM::Synchrony::FiberIterator.new(@outputs, @output

2熱

2答えて

Rubyで複数のWebSocketに接続する方法は？ <a href="https://github.com/faye/faye-websocket-ruby" rel="nofollow noreferrer">faye-websocket</a>を使用し、EventMachineコードは、クライアントの例-のWebSocketをフェイと非常によく似ています

： require 'faye/websocket' require 'eventmachine' def setup_socket(url) EM.run { ws = Faye::WebSocket::Client.new(url) ws.on :open do ... end ws.on :message do ... end

0熱

1答えて

16kに切り捨てられたメッセージがTCPSocketからEventMachineに送信されます

EventMachineで構築されたサービスにデータを送信しようとしているクライアントのルビープロセスがあります。ワークフローは簡単です。クライアントは常に要求を開始し、常に応答を期待します。 TCPSocketからデータを送信するとき、明らかにデータを約16kに切り捨てています。私が間違ってやっていることや、何を前提にして私が考え直す必要があるかに関する推奨事項はありますか？おそらく私は送信され

0熱

2答えて

レール：ポートが使用中であるか、レール4.1.1サーバーを起動しようとしたとき、私はこのエラーを取得しています

root権限が必要です。 Listening on 0.0.0.0:3000, CTRL+C to stop Exiting /Users/darrenburgess/.rvm/gems/[email protected]/gems/eventmachine-1.0.0/lib/eventmachine.rb:526:in `start_tcp_server': no acceptor (po

0熱

1答えて

このようなセットアップでEvent Machineを停止するには？

私はSynatraアプリを持っており、全体としてここに記載されているように構成されていますsinatra docs。基本的にイベントマシンループを開始します。 RSpecテストを作成したい場合は、このようなサーバーを起動してからシャットダウンするにはどうしたらいいですか？私はコンソールからruby server.rbでこれを行うことができますが、私はテストスーツの設定でスペックファイルからこの

0熱

2答えて

ターミナルでRubyスクリプトを実行すると「awake」のままで、ファイルの最後に到達しても終了しないでください

私はTerminalでテストしているRubyスクリプトを持っています。このコードでは、それはすぐに戻りますが、目を覚ましたままで、任意の応答出力していません： client = TweetStream::Client.new(credentials) client.on_direct_message do |direct_message| puts 'direct message: '