@Override
    public void handleChannelData(final String action, final JSONArray jsonArray) throws BitfinexClientException {
        try {
            final List<BitfinexExecutedTrade> trades = new ArrayList<>();

            if( action == "tu") {
                return; // Ignore tu messages (see issue #13)
            }

            // Snapshots contain multiple executes entries, updates only one
            if (jsonArray.get(0) instanceof JSONArray) {
                for (int pos = 0; pos < jsonArray.length(); pos++) {
                    final JSONArray parts = jsonArray.getJSONArray(pos);
                    BitfinexExecutedTrade trade = jsonToExecutedTrade(parts);
                    trades.add(trade);
                }
            } else {
                BitfinexExecutedTrade trade = jsonToExecutedTrade(jsonArray);
                trades.add(trade);
            }
            executedTradesConsumer.accept(symbol, trades);
        } catch (JSONException e) {
            throw new BitfinexClientException(e);
        }
    }
@ Override public void handleChannelData ( final String action , final JSONArray jsonArray ) throws BitfinexClientException { try { final List < BitfinexExecutedTrade > trades = new ArrayList < > ( ) ; if ( action == "tu" ) { return ; } if ( jsonArray . get ( 0 ) instanceof JSONArray ) { for ( int pos = 0 ; pos < jsonArray . length ( ) ; pos ++ ) { final JSONArray parts = jsonArray . getJSONArray ( pos ) ; BitfinexExecutedTrade trade = jsonToExecutedTrade ( parts ) ; trades . add ( trade ) ; } } else { BitfinexExecutedTrade trade = jsonToExecutedTrade ( jsonArray ) ; trades . add ( trade ) ; } executedTradesConsumer . accept ( symbol , trades ) ; } catch ( JSONException e ) { throw new BitfinexClientException ( e ) ; } }
{@inheritDoc}