Seastar
High performance C++ framework for concurrent servers
Public Types | Public Member Functions | List of all members
seastar::stream< T > Class Template Reference

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)
 

The documentation for this class was generated from the following file: