Method attach

Libraries/Http/HttpWebSocket.cpp:1279–1315

}

Result HttpWebSocketConnectionPump::attach(const HttpWebSocketTransportView& newTransport,
                                           HttpWebSocketEndpointRole         endpointRole)
{
    SC_TRY_MSG(newTransport.isValid(), "HttpWebSocketConnectionPump transport is invalid");
    detach();

    transport = newTransport;
    endpoint.reset(endpointRole);
    endpoint.onDataFramePayload.bind<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onEndpointDataFrame>(
        *this);

    dataListenerAdded = transport.readableStream->eventData
                            .addListener<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onData>(*this);
    if (not dataListenerAdded)
    {
        detach();
        return Result::Error("HttpWebSocketConnectionPump data listener limit reached");
    }

    endListenerAdded = transport.readableStream->eventEnd
                           .addListener<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onStreamEnd>(*this);
    if (not endListenerAdded)
    {
        detach();
        return Result::Error("HttpWebSocketConnectionPump end listener limit reached");
    }

    closeListenerAdded =
        transport.readableStream->eventClose
            .addListener<HttpWebSocketConnectionPump, &HttpWebSocketConnectionPump::onStreamEnd>(*this);
    if (not closeListenerAdded)
    {
        detach();
        return Result::Error("HttpWebSocketConnectionPump close listener limit reached");
    }
    return Result(true);
}

void HttpWebSocketConnectionPump::detach()
{