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: