Sha256: c58de0deab5e5f00c94cc57b443e43a9d05218a7d3f9f28079e38a953270b1ea
Contents?: true
Size: 857 Bytes
Versions: 15
Compression:
Stored size: 857 Bytes
Contents
# frozen_string_literal: true
module AnyCable
module Rails
module Middlewares
# Executor runs Rails executor for each call
# See https://guides.rubyonrails.org/v5.2.0/threading_and_code_execution.html#framework-behavior
class Executor < AnyCable::Middleware
attr_reader :executor
def initialize(executor)
@executor = executor
end
def call(method, message, metadata)
sid = metadata["sid"]
if ::Rails.respond_to?(:error)
executor.wrap do
::Rails.error.record(context: {method: method, payload: message.to_h, sid: sid}) do
Rails.with_socket_id(sid) { yield }
end
end
else
executor.wrap { Rails.with_socket_id(sid) { yield } }
end
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems