Sha256: 0eab6e42fa3b5e3ac9cf9639ffe43444464a66df379ce66f5adb97d2f9c5ea59

Contents?: true

Size: 219 Bytes

Versions: 11

Compression:

Stored size: 219 Bytes

Contents

# frozen_string_literal: true

# Threading is not supported!
module Async::Bus
  class << self
    def get(name = :default)
      @buses ||= {}
      @buses[name] ||= Bus.new(name:)
      @buses[name]
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version Path
async-tools-0.1.10 lib/async/bus.rb
async-tools-0.1.9 lib/async/bus.rb
async-tools-0.1.8 lib/async/bus.rb
async-tools-0.1.7 lib/async/bus.rb
async-tools-0.1.6 lib/async/bus.rb
async-tools-0.1.5 lib/async/bus.rb
async-tools-0.1.4 lib/async/bus.rb
async-tools-0.1.3 lib/async/bus.rb
async-tools-0.1.2 lib/async/bus.rb
async-tools-0.1.1 lib/async/bus.rb
async-tools-0.1.0 lib/async/bus.rb