1 #ifndef PROTON_EVENT_LOOP_HPP
2 #define PROTON_EVENT_LOOP_HPP
25 #include "./internal/config.hpp"
26 #include "./function.hpp"
32 #include <type_traits>
35 struct pn_connection_t;
47 virtual void on_inject() = 0;
68 #if PN_CPP_HAS_STD_FUNCTION
69 virtual bool inject(std::function<
void()> f) = 0;
77 PN_CPP_EXTERN
static event_loop*
get(pn_connection_t*);
78 PN_CPP_EXTERN
static event_loop*
get(pn_session_t*);
79 PN_CPP_EXTERN
static event_loop*
get(pn_link_t*);
89 #endif // PROTON_EVENT_LOOP_HPP
A connection to a remote AMQP peer.
Definition: connection.hpp:48
void operator()()
Override the call operator with your code.
Definition: event_loop.hpp:48
Experimental - A serial execution context.
Definition: event_loop.hpp:57
A C++03 compatible void no-argument callback function object, used by container::schedule() and event...
Definition: function.hpp:33
Experimental - A thread-safe object wrapper.
Definition: connection.hpp:45
Experimental - A handler for injected code.
Definition: event_loop.hpp:44
Type traits for mapping between AMQP and C++ types.
Definition: annotation_key.hpp:28