How to use the @microsoft/signalr.HttpTransportType.HttpStreaming function in @microsoft/signalr

To help you get started, we’ve selected a few @microsoft/signalr examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github dotnet / aspnetcore / src / SignalR / clients / ts / FunctionalTests / ts / ConnectionTests.ts View on Github external
eachHttpClient((httpClient) => {
            if (transportType === HttpTransportType.HttpStreaming && !httpClient.supportsStreaming) {
                return;
            }
            describe(`over ${HttpTransportType[transportType]} with ${(httpClient.constructor as any).name}`, () => {
                it("can send and receive messages", (done) => {
                    const message = "Hello World!";
                    // the url should be resolved relative to the document.location.host
                    // and the leading '/' should be automatically added to the url
                    const connection = new HttpConnection(ECHOENDPOINT_URL, {
                        ...commonOptions,
                        httpClient,
                        transport: transportType,
                    });

                    connection.onreceive = (data: any) => {
                        if ((typeof data === "string" && data === message) ||
                            (data instanceof ArrayBuffer && new TextDecoder("utf-8").decode(data) === message)) {
github dotnet / aspnetcore / src / SignalR / clients / ts / FunctionalTests / ts / Common.ts View on Github external
export function getHttpTransportTypes(): HttpTransportType[] {
    const transportTypes = [];
    if (typeof window === "undefined") {
        transportTypes.push(HttpTransportType.WebSockets);
        transportTypes.push(HttpTransportType.ServerSentEvents);
    } else {
        if (typeof WebSocket !== "undefined") {
            transportTypes.push(HttpTransportType.WebSockets);
        }
        if (typeof EventSource !== "undefined") {
            transportTypes.push(HttpTransportType.ServerSentEvents);
        }
    }
    transportTypes.push(HttpTransportType.HttpStreaming);
    transportTypes.push(HttpTransportType.LongPolling);

    return transportTypes;
}
github dotnet / aspnetcore / src / SignalR / clients / ts / FunctionalTests / ts / Common.ts View on Github external
getHttpClients().forEach((httpClient) => {
            if (transport === HttpTransportType.HttpStreaming && !httpClient.supportsStreaming) {
                return;
            }
            action(transport, protocol, httpClient);
        });
    });