streaming_io_peer

Description

Vars

own< conveyor_feeder < data < Incoming, ContentEncoding > > >	incoming_feeder_	nullptr

own< async_io_stream < Net > >	io_stream_

transport < TransportEncoding >	in_codec_

BufferT	in_buffer_

BufferT	out_buffer_

conveyor_sink	sink_read_

conveyor_sink	sink_write_

peer_conveyor_feeder	conveyor_feeder_

conveyor_sink	io_read_disconnected_

own< conveyor_feeder < void > >	disconnect_feeder_	nullptr

Methods

	streaming_io_peer ( own< conveyor_feeder < data < Incoming, ContentEncoding > > >, own< async_io_stream < Net > >, transport < TransportEncoding > )

	streaming_io_peer ( own< conveyor_feeder < data < Incoming, ContentEncoding > > >, own< async_io_stream < Net > > )

	SAW_FORBID_COPY ( streaming_io_peer )

	SAW_FORBID_MOVE ( streaming_io_peer )

error_or < void >	send ( data < Outgoing, ContentEncoding > )

conveyor_feeder < data < Outgoing, ContentEncoding > > &	feeder ( )

conveyor < void >	on_disconnected ( )

Vars Description

own< conveyor_feeder < data < Incoming, ContentEncoding > > > incoming_feeder_

own< async_io_stream < Net > > io_stream_

transport < TransportEncoding > in_codec_

BufferT in_buffer_

BufferT out_buffer_

conveyor_sink sink_read_

conveyor_sink sink_write_

peer_conveyor_feeder conveyor_feeder_

conveyor_sink io_read_disconnected_

own< conveyor_feeder < void > > disconnect_feeder_

Methods Description

streaming_io_peer ( own< conveyor_feeder < data < Incoming, ContentEncoding > > >, own< async_io_stream < Net > >, transport < TransportEncoding > )

Constructor with the option to provide a custom codec, in and out buffer

streaming_io_peer ( own< conveyor_feeder < data < Incoming, ContentEncoding > > >, own< async_io_stream < Net > > )

Constructor with mostly default assignements

SAW_FORBID_COPY ( streaming_io_peer )

Deleted copy and move constructors

SAW_FORBID_MOVE ( streaming_io_peer )

error_or < void > send ( data < Outgoing, ContentEncoding > )

Send a message to the remote peer

conveyor_feeder < data < Outgoing, ContentEncoding > > & feeder ( )

A phantom conveyor feeder. Meant for interfacing with other components

conveyor < void > on_disconnected ( )