Class: Hanami::Events::CloudPubsub::Middleware::Stack
- Inherits:
-
Object
- Object
- Hanami::Events::CloudPubsub::Middleware::Stack
- Defined in:
- lib/hanami/events/cloud_pubsub/middleware/stack.rb
Overview
Middleware which is invoked when a message is received
Defined Under Namespace
Classes: InvalidMiddlewareError
Instance Attribute Summary collapse
-
#entries ⇒ Object
readonly
Returns the value of attribute entries.
Instance Method Summary collapse
- #<<(middleware) ⇒ Object
-
#initialize(*entries) {|_self| ... } ⇒ Stack
constructor
A new instance of Stack.
- #invoke(*args, **kwargs) ⇒ Object
- #prepend(middleware) ⇒ Object
- #shift ⇒ Object
Constructor Details
#initialize(*entries) {|_self| ... } ⇒ Stack
Returns a new instance of Stack.
21 22 23 24 25 |
# File 'lib/hanami/events/cloud_pubsub/middleware/stack.rb', line 21 def initialize(*entries) entries.each(&method(:ensure_callable)) @entries = entries yield self if block_given? end |
Instance Attribute Details
#entries ⇒ Object (readonly)
Returns the value of attribute entries.
19 20 21 |
# File 'lib/hanami/events/cloud_pubsub/middleware/stack.rb', line 19 def entries @entries end |
Instance Method Details
#<<(middleware) ⇒ Object
27 28 29 30 31 |
# File 'lib/hanami/events/cloud_pubsub/middleware/stack.rb', line 27 def <<(middleware) ensure_callable(middleware) entries << middleware self end |
#invoke(*args, **kwargs) ⇒ Object
43 44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/hanami/events/cloud_pubsub/middleware/stack.rb', line 43 def invoke(*args, **kwargs) stack = entries.dup traverse_stack = proc do |**opts| if stack.empty? yield(*args, **kwargs, **opts) else stack.shift.call(*args, **kwargs, **opts, &traverse_stack) end end traverse_stack.call end |
#prepend(middleware) ⇒ Object
33 34 35 36 37 |
# File 'lib/hanami/events/cloud_pubsub/middleware/stack.rb', line 33 def prepend(middleware) ensure_callable(middleware) entries.insert 0, middleware self end |
#shift ⇒ Object
39 40 41 |
# File 'lib/hanami/events/cloud_pubsub/middleware/stack.rb', line 39 def shift @entries.shift end |