#include "remoting/protocol/stream_message_pipe_adapter.h"
#include <memory>
#include <utility>
#include "base/functional/bind.h"
#include "net/base/net_errors.h"
#include "net/traffic_annotation/network_traffic_annotation.h"
#include "remoting/base/buffered_socket_writer.h"
#include "remoting/base/compound_buffer.h"
#include "remoting/protocol/message_serialization.h"
#include "remoting/protocol/p2p_stream_socket.h"
#include "remoting/protocol/stream_channel_factory.h"
namespace remoting::protocol {
StreamMessagePipeAdapter::StreamMessagePipeAdapter(
std::unique_ptr<P2PStreamSocket> socket,
ErrorCallback error_callback)
: … { … }
StreamMessagePipeAdapter::~StreamMessagePipeAdapter() = default;
void StreamMessagePipeAdapter::Start(EventHandler* event_handler) { … }
void StreamMessagePipeAdapter::Send(google::protobuf::MessageLite* message,
base::OnceClosure done) { … }
void StreamMessagePipeAdapter::CloseOnError(int error) { … }
StreamMessageChannelFactoryAdapter::StreamMessageChannelFactoryAdapter(
StreamChannelFactory* stream_channel_factory,
const ErrorCallback& error_callback)
: … { … }
StreamMessageChannelFactoryAdapter::~StreamMessageChannelFactoryAdapter() =
default;
void StreamMessageChannelFactoryAdapter::CreateChannel(
const std::string& name,
ChannelCreatedCallback callback) { … }
void StreamMessageChannelFactoryAdapter::CancelChannelCreation(
const std::string& name) { … }
void StreamMessageChannelFactoryAdapter::OnChannelCreated(
ChannelCreatedCallback callback,
std::unique_ptr<P2PStreamSocket> socket) { … }
}