Method: RxRuby::Subject::AnonymousSubject#initialize

Defined in:
lib/rx_ruby/subjects/subject_extensions.rb

#initialize(observer, observable) ⇒ AnonymousSubject

Returns a new instance of AnonymousSubject.



20
21
22
23
 
# File 'lib/rx_ruby/subjects/subject_extensions.rb', line 20

def initialize(observer, observable)
  @observer = observer
  @observable = observable
end