API Documentation

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.WebSocket;
import java.util.concurrent.CompletionStage;

public class WebSocketClient {
    public static void main(String[] args) {
        HttpClient client = HttpClient.newHttpClient();
        WebSocket ws = client.newWebSocketBuilder()
            .buildAsync(URI.create("wss://evo-hub.live/data?pool=pool_name_that_you_want"), new WebSocket.Listener() {
                @Override
                public CompletionStage onText(WebSocket webSocket, CharSequence data, boolean last) {
                    System.out.println("Received: " + data);
                    return WebSocket.Listener.super.onText(webSocket, data, last);
                }
            }).join();
        ws.sendText("Hello Server!", true);
    }
}Copy

<?php
$host = 'wss://evo-hub.live/data?pool=pool_name_that_you_want';
$socket = fsockopen('tcp://' . parse_url($host, PHP_URL_HOST), parse_url($host, PHP_URL_PORT) ?: 443);

if ($socket) {
    fwrite($socket, "Hello Server!");
    while (!feof($socket)) {
        echo fgets($socket, 1024);
    }
    fclose($socket);
}
?>Copy

using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

class Program {
    static async Task Main(string[] args) {
        using var ws = new ClientWebSocket();
        await ws.ConnectAsync(new Uri("wss://evo-hub.live/data?pool=pool_name_that_you_want"), CancellationToken.None);
        var bytes = Encoding.UTF8.GetBytes("Hello Server!");
        await ws.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Text, true, CancellationToken.None);
        var buffer = new byte[1024];
        var result = await ws.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
        Console.WriteLine("Received: " + Encoding.UTF8.GetString(buffer, 0, result.Count));
    }
}Copy

const socket = new WebSocket('wss://evo-hub.live/data?pool=pool_name_that_you_want');

socket.addEventListener('open', function (event) {
    socket.send('Hello Server!');
});

socket.addEventListener('message', function (event) {
    console.log('Received:', event.data);
});Copy

use tokio_tungstenite::connect_async;
use tokio::net::TcpStream;
use url::Url;

#[tokio::main]
async fn main() {
    let url = Url::parse("wss://evo-hub.live/data?pool=pool_name_that_you_want").unwrap();
    let (ws_stream, _) = connect_async(url).await.expect("Failed to connect");
    let (mut write, read) = ws_stream.split();

    write.send(tokio_tungstenite::tungstenite::Message::Text("Hello Server!".into())).await.unwrap();

    read.for_each(|message| async {
        match message {
            Ok(msg) => println!("Received: {}", msg),
            Err(e) => eprintln!("Error: {}", e),
        }
    }).await;
}Copy