lib/async/bus/bus.rb in async-tools-0.1.1 vs lib/async/bus/bus.rb in async-tools-0.1.2

@@ -41,9 +41,11 @@
     chan = Async::Channel.new(@limit)
     @subscribers[event_name] << chan
     serve(chan, event_name, callable)
   end
 
+  def async_subscribe(*, **, &) = Async { subscribe(*, **, &) }
+
   def close
     return if @closed
 
     @closed = true