thorn.dispatch.base

Default webhook dispatcher.

class thorn.dispatch.base.Dispatcher(timeout=None, app=None, buffer=False)

app = None

disable_buffer(owner=None)

dispatch_request(request)

enable_buffer(owner=None)

encode_cached(payload, cache, ctype)

encode_payload(data, content_type)

flush_buffer(owner=None)

prepare_requests(event, payload, sender, timeout=None, context=None, extra_subscribers=None, **kwargs)

send(event, payload, sender, context=None, extra_subscribers=None, allow_keepalive=True, **kwargs)

subscribers_for_event(name, sender=None, context={}, extra_subscribers=None)

Return a list of Subscriber subscribing to an event by name (optionally filtered by sender).