Package info.bitrich.xchangestream.okex

Class OkexStreamingTradeService

java.lang.Object

info.bitrich.xchangestream.okex.OkexStreamingTradeService

All Implemented Interfaces:

StreamingTradeService

public class OkexStreamingTradeService
extends Object
implements StreamingTradeService

Constructor Summary

Constructors

Constructor	Description
OkexStreamingTradeService(OkexPrivateStreamingService privateStreamingService, ExchangeMetaData exchangeMetaData, ResilienceRegistries resilienceRegistries)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Single<Integer>	cancelOrder(CancelOrderParams params, Object... args)	Cancels an existing order on the exchange.
io.reactivex.rxjava3.core.Single<Integer>	changeOrder(LimitOrder order, Object... args)	Modifies an existing limit order on the exchange.
io.reactivex.rxjava3.core.Observable<Order>	getOrderChanges(Instrument instrument, Object... args)
io.reactivex.rxjava3.core.Observable<OpenPosition>	getPositionChanges(Instrument instrument)
io.reactivex.rxjava3.core.Observable<UserTrade>	getUserTrades(Instrument instrument, Object... args)
io.reactivex.rxjava3.core.Single<Integer>	placeLimitOrder(LimitOrder order, Object... args)	Places a limit order on the exchange.
io.reactivex.rxjava3.core.Single<Integer>	placeMarketOrder(MarketOrder order, Object... args)	Places a market order on the exchange.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface info.bitrich.xchangestream.core.StreamingTradeService

getOrderChanges, getUserTrades, getUserTrades

Constructor Details

OkexStreamingTradeService

public OkexStreamingTradeService(OkexPrivateStreamingService privateStreamingService,
 ExchangeMetaData exchangeMetaData,
 ResilienceRegistries resilienceRegistries)

Method Details

getOrderChanges

public io.reactivex.rxjava3.core.Observable<Order> getOrderChanges(Instrument instrument,
 Object... args)

Specified by:

getOrderChanges in interface StreamingTradeService

getUserTrades

public io.reactivex.rxjava3.core.Observable<UserTrade> getUserTrades(Instrument instrument,
 Object... args)

Specified by:

getUserTrades in interface StreamingTradeService

getPositionChanges

public io.reactivex.rxjava3.core.Observable<OpenPosition> getPositionChanges(Instrument instrument)

Specified by:

getPositionChanges in interface StreamingTradeService

placeLimitOrder

public io.reactivex.rxjava3.core.Single<Integer> placeLimitOrder(LimitOrder order,
 Object... args)

Description copied from interface: StreamingTradeService

Places a limit order on the exchange. A limit order specifies the price at which the user wants to buy or sell a financial instrument, potentially with additional optional parameters.

Specified by:

placeLimitOrder in interface StreamingTradeService

Parameters:

order - The details of the limit order, including instrument, price, volume, and side (buy/sell).

args - Optional additional arguments that may be required by specific exchanges.

Returns:

A Single that emits the operation result code, typically 0 for success.

placeMarketOrder

public io.reactivex.rxjava3.core.Single<Integer> placeMarketOrder(MarketOrder order,
 Object... args)

Description copied from interface: StreamingTradeService

Places a market order on the exchange. A market order is an order to buy or sell a financial instrument immediately at the best available current price. Specific exchanges may require additional optional parameters to process the market order.

Specified by:

placeMarketOrder in interface StreamingTradeService

Parameters:

order - The details of the market order, including the instrument, amount, and side (buy/sell).

args - Optional additional arguments that may be required by specific exchanges.

Returns:

A Single that emits the operation result code, typically 0 for success.

changeOrder

public io.reactivex.rxjava3.core.Single<Integer> changeOrder(LimitOrder order,
 Object... args)

Description copied from interface: StreamingTradeService

Modifies an existing limit order on the exchange. This can include changes to the price, volume, or other adjustable parameters of the order, depending on the exchange's specific functionality and constraints.

Specified by:

changeOrder in interface StreamingTradeService

Parameters:

order - The limit order to be modified, including the updated details such as price or/and volume.

args - Optional additional arguments that may be required by specific exchanges.

Returns:

A Single that emits the operation result code, typically 0 for success.

cancelOrder

public io.reactivex.rxjava3.core.Single<Integer> cancelOrder(CancelOrderParams params,
 Object... args)

Description copied from interface: StreamingTradeService

Cancels an existing order on the exchange. The operation requires specific parameters describing the order to be canceled, such as order ID or user reference ID.

Specified by:

cancelOrder in interface StreamingTradeService

Parameters:

params - An object implementing CancelOrderParams that contains order ID or user reference ID.

args - Optional additional arguments that may be required by specific exchanges.

Returns:

A Single that emits the operation result code, typically 0 for success.