Class: Akane::Receivers::AbstractReceiver

Inherits:
Object
  • Object
show all
Defined in:
lib/akane/receivers/abstract_receiver.rb

Direct Known Subclasses

Stream

Instance Method Summary collapse

Constructor Details

#initialize(consumer: raise(ArgumentError, 'missing consumer'), account: raise(ArgumentError, 'missing account'), logger: Logger.new($stdout), config: {}) ⇒ AbstractReceiver

Returns a new instance of AbstractReceiver.



4
5
6
7
8
9
10
11
12
13
14
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 4

def initialize(consumer: raise(ArgumentError, 'missing consumer'),
               account:  raise(ArgumentError, 'missing account'),
               logger: Logger.new($stdout),
               config: {})
  @consumer = consumer
  @account = 
  @logger = logger
  @config = config

  @hooks = {}
end

Instance Method Details

#on(kind, &block) ⇒ Object 



28
29
30
31
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 28

def on(kind, &block)
  (@hooks[kind] ||= []) << block
  self
end

#on_delete(&block) ⇒ Object 



34
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 34

def on_delete(&block) on(:delete, &block) end

#on_event(&block) ⇒ Object 



36
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 36

def on_event(&block) on(:event, &block) end

#on_message(&block) ⇒ Object 



35
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 35

def on_message(&block) on(:message, &block) end

#on_tweet(&block) ⇒ Object 



33
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 33

def on_tweet(&block) on(:tweet, &block) end

#running? ⇒ Boolean

Returns:

  • (Boolean)

Raises:

  • (NotImplementedError) 


24
25
26
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 24

def running?
  raise NotImplementedError
end

#start ⇒ Object

Raises:

  • (NotImplementedError) 


16
17
18
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 16

def start
  raise NotImplementedError
end

#stop ⇒ Object

Raises:

  • (NotImplementedError) 


20
21
22
 
# File 'lib/akane/receivers/abstract_receiver.rb', line 20

def stop
  raise NotImplementedError
end