imran0101

import rx.Observable;
import rx.Subscriber;
import rx.Subscription;
import rx.functions.Action0;
import rx.subjects.PublishSubject;
import rx.subjects.SerializedSubject;

/**
 * An object reference of EventBus

benjchristensen

import rx.Observable;
import rx.subjects.PublishSubject;
import rx.subjects.SerializedSubject;
import rx.subjects.Subject;

/**
 * Simple pass-thru event bus with error handling and reconnect.
 */
public class EventBus {

kitallis

class PratulKalia
  class << self
	def should(&sblk)
	  self.new.instance_eval(&sblk)
	end
  end
end

class Blabber
	def things(arg)