Skip to content

Commit

Permalink
[EN-1980] exchange code correction in all events
Browse files Browse the repository at this point in the history
  • Loading branch information
@iamishalkin
iamishalkin committed Oct 6, 2020
1 parent ece8003 commit 0b748ea
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions dxfeed/core/listeners/listener.pyx
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ cdef void trade_default_listener(int event_type,
events[i] = TradeTuple(symbol=unicode_from_dxf_const_string_t(symbol_name),
sequence=trades[i].sequence,
price=trades[i].price,
exchange_code=unicode_from_dxf_const_string_t(&trades[i].exchange_code),
exchange_code=unicode_from_dxf_const_string_t(&trades[i].exchange_code, size=1),
size=trades[i].size,
tick=trades[i].tick,
change=trades[i].change,
Expand Down Expand Up @@ -66,11 +66,11 @@ cdef void quote_default_listener(int event_type,
time=quotes[i].time,
time_nanos=quotes[i].time_nanos,
bid_time=quotes[i].bid_time,
bid_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].bid_exchange_code),
bid_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].bid_exchange_code, size=1),
bid_price=quotes[i].bid_price,
bid_size=quotes[i].bid_size,
ask_time=quotes[i].ask_time,
ask_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].ask_exchange_code),
ask_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].ask_exchange_code, size=1),
ask_price=quotes[i].ask_price,
ask_size=quotes[i].ask_size,
scope=<int> quotes[i].scope)
Expand Down Expand Up @@ -102,7 +102,7 @@ cdef void summary_default_listener(int event_type, dxf_const_string_t symbol_nam
prev_day_volume=summary[i].prev_day_volume,
open_interest=summary[i].open_interest,
raw_flags=summary[i].raw_flags,
exchange_code=unicode_from_dxf_const_string_t(&summary[i].exchange_code),
exchange_code=unicode_from_dxf_const_string_t(&summary[i].exchange_code, size=1),
day_close_price_type=summary[i].day_close_price_type,
prev_day_close_price_type=summary[i].prev_day_close_price_type,
scope=summary[i].scope)
Expand Down Expand Up @@ -166,7 +166,7 @@ cdef void time_and_sale_default_listener(int event_type,
event_flags=tns[i].event_flags,
index=tns[i].index,
time=tns[i].time,
exchange_code=unicode_from_dxf_const_string_t(&tns[i].exchange_code),
exchange_code=unicode_from_dxf_const_string_t(&tns[i].exchange_code, size=1),
price=tns[i].price,
size=tns[i].size,
bid_price=tns[i].bid_price,
Expand Down

0 comments on commit 0b748ea

Please sign in to comment.