Seastar
High performance C++ framework for concurrent servers
|
Public Types | |
using | next_fn = noncopyable_function< future<>(T...)> |
Public Member Functions | |
stream (const stream &)=delete | |
stream (stream &&)=delete | |
void | operator= (const stream &)=delete |
void | operator= (stream &&)=delete |
subscription< T... > | listen () |
subscription< T... > | listen (next_fn next) |
future | started () |
future | produce (T... data) |
void | close () |
template<typename E > | |
void | set_exception (E ex) |