Seastar
High performance C++ framework for concurrent servers
|
Implementation of connection's data sink.
#include <seastar/websocket/common.hh>
Public Member Functions | |
connection_sink_impl (queue< buff_t > *data) | |
virtual future | put (net::packet d) override |
size_t | buffer_size () const noexcept override |
virtual future | close () override |
virtual temporary_buffer< char > | allocate_buffer (size_t size) |
virtual future | put (std::vector< temporary_buffer< char > > data) |
virtual future | put (temporary_buffer< char > buf) |
virtual future | flush () |
virtual bool | can_batch_flushes () const noexcept |
virtual void | on_batch_flush_error () noexcept |
Protected Member Functions | |
future | fallback_put (net::packet data) |
|
inlineoverridevirtualnoexcept |
Reimplemented from seastar::data_sink_impl.
|
inlineoverridevirtual |
Implements seastar::data_sink_impl.
|
inlineoverridevirtual |
Implements seastar::data_sink_impl.