palkan

module ActionCable::Channel::Streams
  def worker_pool_stream_handler(broadcasting, user_handler, coder: nil)
    { connection: connection, id: @identifier.to_json }
  end
end

class ActionCable::SubscriptionAdapter::SubscriberMap
  def invoke_callback(callback, message)
    callback[:connection].send(:websocket).transmit(
      "{\"identifier\": #{callback[:id]},\"message\": #{message}}"

palkan

# rubocop disable:all
begin
  require 'bundler/inline'
rescue LoadError => e
  $stderr.puts 'Bundler version 1.10 or later is required. Please update your Bundler'
  raise e
end

gemfile(true) do
  source 'https://rubygems.org'

palkan

-- show running queries (9.2)
SELECT pid, age(query_start, clock_timestamp()), usename, query 
FROM pg_stat_activity 
WHERE query != '<IDLE>' AND query NOT ILIKE '%pg_stat_activity%' 
ORDER BY query_start desc;

-- kill running query
SELECT pg_cancel_backend(procpid);

-- kill idle query

palkan

def _after_commit_hook
  super unless skip_after_commit_hook
  @_counter_culture_active = false
end

def skip_after_commit_hook
  false  
end

palkan

language: ruby
rvm:
  - 2.2.3

# Если Travis пишет вам слишком часто, то отключаем email уведомления
notifications:
  email: false

# Указываем базу данных
addons:

palkan

shared_context "feature", type: :feature do
  after(:each) do |example|
    next unless example.exception
    meta = example.metadata
    next unless meta[:js] == true
    filename = File.basename(meta[:file_path])
    line_number = meta[:line_number]
    screenshot_name = "screenshot-#{filename}-#{line_number}.png"
    save_screenshot(screenshot_name) # rubocop:disable Lint/Debugger
    puts meta[:full_description] + "\n  Screenshot: #{screenshot_name}"

palkan

# По умолчанию запускаем только необходимых для тестов наблюдателей,
# то есть всех, кроме server.
# Для запуска всех: bundle exec guard -g default
scope groups: ['specs']

group 'specs' do
  # запускаем тесты и использованием Spring
  guard :rspec, cmd: "bundle exec spring rspec" do 
    require "guard/rspec/dsl"
    dsl = Guard::RSpec::Dsl.new(self)

palkan

Pusher = fun(Client, Name, Size) -> F = fun(_, _, _, _, 0) -> io:format('done'); (Fun, C, N, I, Size) -> Segment = "../dash-examples/"++N++integer_to_list(I)++".m4s", io:format("Segment: ~s~n", [Segment]), {ok, B} = file:read_file(Segment), de_client:send(C, {binary, B}), timer:sleep(500), Fun(Fun, C, N, I+1, Size - 1) end, InitName = "../dash-examples/"++Name++"init.mp4", io:format("Init file: ~s~n", [InitName]), {ok,  I} = file:read_file(InitName), de_client:send(Client, {binary, I}), timer:sleep(1500), F(F, Client, Name, 1, Size) end.

palkan

begin
  require 'bundler/inline'
rescue LoadError => e
  $stderr.puts 'Bundler version 1.10 or later is required. Please update your Bundler'
  raise e
end

gemfile(true) do
  source 'https://rubygems.org'
  gem 'rack', github: "rack/rack"

palkan

begin
  require 'bundler/inline'
rescue LoadError => e
  $stderr.puts 'Bundler version 1.10 or later is required. Please update your Bundler'
  raise e
end

gemfile(true) do
  source 'https://rubygems.org'
  gem 'arel', github: 'rails/arel'