2
我是水晶初学者。 我有问题,也许有人可以帮助我。水晶郎光纤和网络插座
我使用凯末尔框架。 有这样的代码:
require "kemal"
require "json"
channel = Channel(Card).new
post "/posts" do |env|
json = JSON.parse(env.request.body as String)
url = json["url"].to_s
spawn do
# Slow process
page = Scraper.new(url)
channel.send(page)
end
{"url" => url}.to_json
end
ws "/" do |socket|
data = channel.receive
socket.send data.to_h.to_json
end
Kemal.run
但结果发送到网络插座只有一次。
(仅在第一次发布后请求)
我该如何解决?
否则,我假定websocket连接在块完成时关闭 – asterite