Market data streaming

from myfundedperps import PriceStream

with PriceStream(["BTCUSDT", "ETHUSDT"], providers=["binance"]) as stream:
    for event in stream:
        if event["type"] == "tick":
            print(event["symbol"], event["kind"], event["price"])

import (
    "context"
    "fmt"

    "github.com/MyFundedPerps/myfundedperps/sdk/go"
)

func readPrices(ctx context.Context) error {
    stream, err := myfundedperps.DialPriceStream(ctx, myfundedperps.PriceStreamConfig{
        Symbols:   []string{"BTCUSDT", "ETHUSDT"},
        Providers: []string{"binance"},
    })
    if err != nil {
        return err
    }
    defer stream.Close()
    for {
        event, err := stream.Next()
        if err != nil {
            return err
        }
        if event.Tick != nil {
            fmt.Println(event.Tick.Symbol, event.Tick.Kind, event.Tick.Price)
        }
    }
}

use myfundedperps::{PriceStream, PriceStreamError, PriceStreamEvent};

fn main() -> Result<(), PriceStreamError> {
    let stream = PriceStream::connect(
        &["BTCUSDT", "ETHUSDT"], Some(&["binance"]),
    )?;
    for event in stream {
        if let PriceStreamEvent::Tick(tick) = event? {
            println!("{} {:?} {}", tick.symbol, tick.kind, tick.price);
        }
    }
    Ok(())
} // Dropping the stream closes the connection.

import com.myfundedperps.sdk.PriceStream;
import com.myfundedperps.sdk.PriceStreamEvent;
import java.util.List;

try (PriceStream stream = PriceStream.connect(
    List.of("BTCUSDT", "ETHUSDT"), List.of("binance"))) {
  PriceStreamEvent event;
  while ((event = stream.next()) != null) {
    if (event.tick != null) {
      System.out.println(event.tick.symbol + " " + event.tick.kind + " " + event.tick.price);
    }
  }
}

require 'vendor/autoload.php';

use MyFundedPerps\Sdk\PriceStream;

$stream = new PriceStream(['BTCUSDT', 'ETHUSDT'], ['binance']);
try {
    foreach ($stream as $event) {
        if ($event->tick !== null) {
            echo $event->tick->symbol . ' ' . $event->tick->kind . ' ' . $event->tick->price . PHP_EOL;
        }
    }
} finally {
    $stream->close();
}