lib/hanami/events/cloud_pubsub/runner.rb
# Will be called on TSTP
#
# Stop processing new events (unsubscribe from topics, etc)
Will be called on TSTP
Stop processing new events (unsubscribe from topics, etc)
Will be called on TSTP Stop processing new events ( unsubscribe from topics etc )
def stop
          logger.info 'Stopping CloudPubsub listeners'
          adapter.listeners.each(&:stop)
          self
        end
def stop logger . info 'Stopping CloudPubsub listeners' adapter . listeners . each ( & :stop ) self end
Will be called on TSTP
Stop processing new events (unsubscribe from topics, etc)
Will be called on TSTP Stop processing new events ( unsubscribe from topics etc )