Skip to content

Commit 0b748ea

Browse files
committed
[EN-1980] exchange code correction in all events
1 parent ece8003 commit 0b748ea

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

dxfeed/core/listeners/listener.pyx

+5-5
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ cdef void trade_default_listener(int event_type,
3131
events[i] = TradeTuple(symbol=unicode_from_dxf_const_string_t(symbol_name),
3232
sequence=trades[i].sequence,
3333
price=trades[i].price,
34-
exchange_code=unicode_from_dxf_const_string_t(&trades[i].exchange_code),
34+
exchange_code=unicode_from_dxf_const_string_t(&trades[i].exchange_code, size=1),
3535
size=trades[i].size,
3636
tick=trades[i].tick,
3737
change=trades[i].change,
@@ -66,11 +66,11 @@ cdef void quote_default_listener(int event_type,
6666
time=quotes[i].time,
6767
time_nanos=quotes[i].time_nanos,
6868
bid_time=quotes[i].bid_time,
69-
bid_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].bid_exchange_code),
69+
bid_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].bid_exchange_code, size=1),
7070
bid_price=quotes[i].bid_price,
7171
bid_size=quotes[i].bid_size,
7272
ask_time=quotes[i].ask_time,
73-
ask_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].ask_exchange_code),
73+
ask_exchange_code=unicode_from_dxf_const_string_t(&quotes[i].ask_exchange_code, size=1),
7474
ask_price=quotes[i].ask_price,
7575
ask_size=quotes[i].ask_size,
7676
scope=<int> quotes[i].scope)
@@ -102,7 +102,7 @@ cdef void summary_default_listener(int event_type, dxf_const_string_t symbol_nam
102102
prev_day_volume=summary[i].prev_day_volume,
103103
open_interest=summary[i].open_interest,
104104
raw_flags=summary[i].raw_flags,
105-
exchange_code=unicode_from_dxf_const_string_t(&summary[i].exchange_code),
105+
exchange_code=unicode_from_dxf_const_string_t(&summary[i].exchange_code, size=1),
106106
day_close_price_type=summary[i].day_close_price_type,
107107
prev_day_close_price_type=summary[i].prev_day_close_price_type,
108108
scope=summary[i].scope)
@@ -166,7 +166,7 @@ cdef void time_and_sale_default_listener(int event_type,
166166
event_flags=tns[i].event_flags,
167167
index=tns[i].index,
168168
time=tns[i].time,
169-
exchange_code=unicode_from_dxf_const_string_t(&tns[i].exchange_code),
169+
exchange_code=unicode_from_dxf_const_string_t(&tns[i].exchange_code, size=1),
170170
price=tns[i].price,
171171
size=tns[i].size,
172172
bid_price=tns[i].bid_price,

0 commit comments

Comments
 (0)