info.bitrich.xchangestream.lgo

Class LgoStreamingTradeService

java.lang.Object

info.bitrich.xchangestream.lgo.LgoStreamingTradeService

All Implemented Interfaces:

StreamingTradeService

public class LgoStreamingTradeService
extends Object
implements StreamingTradeService

Method Summary

Modifier and Type	Method and Description
boolean	cancelOrder(String orderId) Place a cancel order
io.reactivex.Observable<org.knowm.xchange.dto.trade.OpenOrders>	getOpenOrders(org.knowm.xchange.currency.CurrencyPair currencyPair) Get an up-to-date view of all your open orders after each LGO batch execution.
io.reactivex.Observable<Collection<org.knowm.xchange.dto.Order>>	getOrderBatchChanges(org.knowm.xchange.currency.CurrencyPair currencyPair) Receive all updated orders, for each LGO batches.
io.reactivex.Observable<org.knowm.xchange.dto.Order>	getOrderChanges(org.knowm.xchange.currency.CurrencyPair currencyPair, Object... args) First sent orders will be current open orders.
io.reactivex.Observable<LgoOrderEvent>	getRawAllOrderEvents(Collection<org.knowm.xchange.currency.CurrencyPair> currencyPairs) Receive all events for the selected currency pairs.
io.reactivex.Observable<LgoOrderEvent>	getRawBatchOrderEvents(org.knowm.xchange.currency.CurrencyPair currencyPair) Get all events of your orders happened during batch execution, for a currency pair.
io.reactivex.Observable<LgoOrderEvent>	getRawReceivedOrderEvents() Get ack for your placed orders.
io.reactivex.Observable<org.knowm.xchange.dto.trade.UserTrade>	getUserTrades(org.knowm.xchange.currency.CurrencyPair currencyPair, Object... args)
String	placeLimitOrder(org.knowm.xchange.dto.trade.LimitOrder limitOrder) Place a limit order
String	placeMarketOrder(org.knowm.xchange.dto.trade.MarketOrder marketOrder) Place a market order

Methods inherited from class java.lang.Object

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

Method Detail

getOrderChanges

public io.reactivex.Observable<org.knowm.xchange.dto.Order> getOrderChanges(org.knowm.xchange.currency.CurrencyPair currencyPair,
                                                                            Object... args)

First sent orders will be current open orders.

Specified by:

getOrderChanges in interface StreamingTradeService

getOpenOrders

public io.reactivex.Observable<org.knowm.xchange.dto.trade.OpenOrders> getOpenOrders(org.knowm.xchange.currency.CurrencyPair currencyPair)

Get an up-to-date view of all your open orders after each LGO batch execution. First sending will be the actual open orders list.

getOrderBatchChanges

public io.reactivex.Observable<Collection<org.knowm.xchange.dto.Order>> getOrderBatchChanges(org.knowm.xchange.currency.CurrencyPair currencyPair)

Receive all updated orders, for each LGO batches. First sending will be the actual open orders list.

getUserTrades

public io.reactivex.Observable<org.knowm.xchange.dto.trade.UserTrade> getUserTrades(org.knowm.xchange.currency.CurrencyPair currencyPair,
                                                                                    Object... args)

Specified by:

getUserTrades in interface StreamingTradeService

getRawAllOrderEvents

public io.reactivex.Observable<LgoOrderEvent> getRawAllOrderEvents(Collection<org.knowm.xchange.currency.CurrencyPair> currencyPairs)

Receive all events for the selected currency pairs. Merges batch order events and ack (AFR) events.

getRawReceivedOrderEvents

public io.reactivex.Observable<LgoOrderEvent> getRawReceivedOrderEvents()

Get ack for your placed orders. "received" events indicate the orderId associated to your order, if you set a reference on order placement you will have it in the event. "failed" events indicate that the order could not be read or was invalid and not added to a batch.

getRawBatchOrderEvents

public io.reactivex.Observable<LgoOrderEvent> getRawBatchOrderEvents(org.knowm.xchange.currency.CurrencyPair currencyPair)

Get all events of your orders happened during batch execution, for a currency pair. "pending" events indicate that the order was added to a batch and received by the execution engine. "invalid" events indicate that the order was not suitable for execution. "match" events indicate that the order did match against another order. "open" events indicate that the order entered the order book. "done" events indicate that the order was filled, canceled or rejected.

placeMarketOrder

public String placeMarketOrder(org.knowm.xchange.dto.trade.MarketOrder marketOrder)
                        throws IOException

Place a market order

Returns:

the order reference

Throws:

IOException

placeLimitOrder

public String placeLimitOrder(org.knowm.xchange.dto.trade.LimitOrder limitOrder)
                       throws IOException

Place a limit order

Returns:

the order reference

Throws:

IOException

cancelOrder

public boolean cancelOrder(String orderId)
                    throws IOException

Place a cancel order

Returns:

true

Throws:

IOException