Seastar
High performance C++ framework for concurrent servers
|
Public Types | |
using | next_fn = typename stream< T... >::next_fn |
Public Member Functions | |
subscription (subscription &&x) | |
void | start (next_fn next) |
Start receiving events from the stream. More... | |
future | done () |
|
inline |
Start receiving events from the stream.
next | Callback to call for each event |