Skip to content

Commit bc9017a

Browse files
umernallaumernalla
committed
rename item_stream to stream
1 parent 09768c9 commit bc9017a

File tree

2 files changed

+48
-66
lines changed

2 files changed

+48
-66
lines changed

‎Tutorials/3.Delivery/3.1-Streaming/TUT_3.1.01-OMMStream-MarketPrice.ipynb‎

Lines changed: 44 additions & 62 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@
7070
{
7171
"data": {
7272
"text/plain": [
73-
"<refinitiv.data.session.platform.Definition object at 0x1b36bb9cd00 {session_name='rdp'}>"
73+
"<refinitiv.data.session.platform.Definition object at 0x1203e90fc10 {session_name='rdp'}>"
7474
]
7575
},
7676
"execution_count": 3,
@@ -119,7 +119,7 @@
119119
{
120120
"data": {
121121
"text/plain": [
122-
"<refinitiv.data.delivery.omm_stream.OMMStream object at 0x1b31b5d2430>"
122+
"<refinitiv.data.delivery.omm_stream.OMMStream object at 0x1203eb451f0>"
123123
]
124124
},
125125
"execution_count": 5,
@@ -134,13 +134,13 @@
134134
" domain='MarketPrice').get_stream()\n",
135135
"\n",
136136
"# Refresh - the first full imaage we get back from the server\n",
137-
"stream.on_refresh(lambda item_stream, event : display_event(\"Refresh\", event))\n",
137+
"stream.on_refresh(lambda stream, event : display_event(\"Refresh\", event))\n",
138138
"# Update - as and when field values change, we receive updates from the server\n",
139-
"stream.on_update(lambda item_stream, event : display_event(\"Update\", event))\n",
139+
"stream.on_update(lambda stream, event : display_event(\"Update\", event))\n",
140140
"# Status - if data goes stale or item closes, we get a status message\n",
141-
"stream.on_status(lambda item_stream, event : display_event(\"Status\", event))\n",
141+
"stream.on_status(lambda stream, event : display_event(\"Status\", event))\n",
142142
"# Other errors\n",
143-
"stream.on_error(lambda item_stream, event : display_event(\"Error\", event))"
143+
"stream.on_error(lambda stream, event : display_event(\"Error\", event))"
144144
]
145145
},
146146
{
@@ -165,7 +165,7 @@
165165
"output_type": "stream",
166166
"text": [
167167
"----------------------------------------------------------\n",
168-
">>> Refresh event received at 12:16:01.118182\n",
168+
">>> Refresh event received at 10:26:05.938979\n",
169169
"{\n",
170170
" \"ID\": 1,\n",
171171
" \"Type\": \"Refresh\",\n",
@@ -182,13 +182,13 @@
182182
" \"Rate\": \"JitConflated\"\n",
183183
" },\n",
184184
" \"PermData\": \"AwEBUmw=\",\n",
185-
" \"SeqNumber\": 1902,\n",
185+
" \"SeqNumber\": 39550,\n",
186186
" \"Fields\": {\n",
187-
" \"TIMACT\": \"12:16:00\",\n",
188-
" \"OPEN_PRC\": 1.1206,\n",
189-
" \"HST_CLOSE\": 1.1206,\n",
190-
" \"BID\": 1.1275,\n",
191-
" \"ASK\": 1.1279\n",
187+
" \"TIMACT\": \"10:26:00\",\n",
188+
" \"OPEN_PRC\": 1.1259,\n",
189+
" \"HST_CLOSE\": 1.1257,\n",
190+
" \"BID\": 1.127,\n",
191+
" \"ASK\": 1.1273\n",
192192
" }\n",
193193
"}\n"
194194
]
@@ -208,7 +208,7 @@
208208
"output_type": "stream",
209209
"text": [
210210
"----------------------------------------------------------\n",
211-
">>> Update event received at 12:16:01.349115\n",
211+
">>> Update event received at 10:26:06.011530\n",
212212
"{\n",
213213
" \"ID\": 1,\n",
214214
" \"Type\": \"Update\",\n",
@@ -218,15 +218,15 @@
218218
" \"Service\": \"ELEKTRON_DD\",\n",
219219
" \"Name\": \"EUR=\"\n",
220220
" },\n",
221-
" \"SeqNumber\": 1918,\n",
221+
" \"SeqNumber\": 39566,\n",
222222
" \"Fields\": {\n",
223-
" \"BID\": 1.1276,\n",
224-
" \"ASK\": 1.1278,\n",
225-
" \"TIMACT\": \"12:16:00\"\n",
223+
" \"BID\": 1.1272,\n",
224+
" \"ASK\": 1.1275,\n",
225+
" \"TIMACT\": \"10:26:00\"\n",
226226
" }\n",
227227
"}\n",
228228
"----------------------------------------------------------\n",
229-
">>> Update event received at 12:16:01.349115\n",
229+
">>> Update event received at 10:26:07.000999\n",
230230
"{\n",
231231
" \"ID\": 1,\n",
232232
" \"Type\": \"Update\",\n",
@@ -236,15 +236,15 @@
236236
" \"Service\": \"ELEKTRON_DD\",\n",
237237
" \"Name\": \"EUR=\"\n",
238238
" },\n",
239-
" \"SeqNumber\": 1982,\n",
239+
" \"SeqNumber\": 39630,\n",
240240
" \"Fields\": {\n",
241-
" \"BID\": 1.1276,\n",
242-
" \"ASK\": 1.1277,\n",
243-
" \"TIMACT\": \"12:16:00\"\n",
241+
" \"BID\": 1.127,\n",
242+
" \"ASK\": 1.1273,\n",
243+
" \"TIMACT\": \"10:26:00\"\n",
244244
" }\n",
245245
"}\n",
246246
"----------------------------------------------------------\n",
247-
">>> Update event received at 12:16:01.849395\n",
247+
">>> Update event received at 10:26:08.002936\n",
248248
"{\n",
249249
" \"ID\": 1,\n",
250250
" \"Type\": \"Update\",\n",
@@ -254,15 +254,15 @@
254254
" \"Service\": \"ELEKTRON_DD\",\n",
255255
" \"Name\": \"EUR=\"\n",
256256
" },\n",
257-
" \"SeqNumber\": 2046,\n",
257+
" \"SeqNumber\": 39694,\n",
258258
" \"Fields\": {\n",
259-
" \"BID\": 1.1275,\n",
260-
" \"ASK\": 1.1279,\n",
261-
" \"TIMACT\": \"12:16:00\"\n",
259+
" \"BID\": 1.1272,\n",
260+
" \"ASK\": 1.1275,\n",
261+
" \"TIMACT\": \"10:26:00\"\n",
262262
" }\n",
263263
"}\n",
264264
"----------------------------------------------------------\n",
265-
">>> Update event received at 12:16:02.838731\n",
265+
">>> Update event received at 10:26:08.991996\n",
266266
"{\n",
267267
" \"ID\": 1,\n",
268268
" \"Type\": \"Update\",\n",
@@ -272,15 +272,15 @@
272272
" \"Service\": \"ELEKTRON_DD\",\n",
273273
" \"Name\": \"EUR=\"\n",
274274
" },\n",
275-
" \"SeqNumber\": 2110,\n",
275+
" \"SeqNumber\": 39758,\n",
276276
" \"Fields\": {\n",
277-
" \"BID\": 1.1275,\n",
278-
" \"ASK\": 1.1279,\n",
279-
" \"TIMACT\": \"12:16:00\"\n",
277+
" \"BID\": 1.127,\n",
278+
" \"ASK\": 1.1273,\n",
279+
" \"TIMACT\": \"10:26:00\"\n",
280280
" }\n",
281281
"}\n",
282282
"----------------------------------------------------------\n",
283-
">>> Update event received at 12:16:03.348669\n",
283+
">>> Update event received at 10:26:09.652304\n",
284284
"{\n",
285285
" \"ID\": 1,\n",
286286
" \"Type\": \"Update\",\n",
@@ -290,15 +290,15 @@
290290
" \"Service\": \"ELEKTRON_DD\",\n",
291291
" \"Name\": \"EUR=\"\n",
292292
" },\n",
293-
" \"SeqNumber\": 2174,\n",
293+
" \"SeqNumber\": 39822,\n",
294294
" \"Fields\": {\n",
295-
" \"BID\": 1.1275,\n",
296-
" \"ASK\": 1.1278,\n",
297-
" \"TIMACT\": \"12:16:00\"\n",
295+
" \"BID\": 1.127,\n",
296+
" \"ASK\": 1.1273,\n",
297+
" \"TIMACT\": \"10:26:00\"\n",
298298
" }\n",
299299
"}\n",
300300
"----------------------------------------------------------\n",
301-
">>> Update event received at 12:16:04.928779\n",
301+
">>> Update event received at 10:26:10.001258\n",
302302
"{\n",
303303
" \"ID\": 1,\n",
304304
" \"Type\": \"Update\",\n",
@@ -308,29 +308,11 @@
308308
" \"Service\": \"ELEKTRON_DD\",\n",
309309
" \"Name\": \"EUR=\"\n",
310310
" },\n",
311-
" \"SeqNumber\": 2238,\n",
311+
" \"SeqNumber\": 39886,\n",
312312
" \"Fields\": {\n",
313-
" \"BID\": 1.1275,\n",
314-
" \"ASK\": 1.1278,\n",
315-
" \"TIMACT\": \"12:16:00\"\n",
316-
" }\n",
317-
"}\n",
318-
"----------------------------------------------------------\n",
319-
">>> Update event received at 12:16:05.849336\n",
320-
"{\n",
321-
" \"ID\": 1,\n",
322-
" \"Type\": \"Update\",\n",
323-
" \"UpdateType\": \"Unspecified\",\n",
324-
" \"DoNotConflate\": true,\n",
325-
" \"Key\": {\n",
326-
" \"Service\": \"ELEKTRON_DD\",\n",
327-
" \"Name\": \"EUR=\"\n",
328-
" },\n",
329-
" \"SeqNumber\": 2302,\n",
330-
" \"Fields\": {\n",
331-
" \"BID\": 1.1275,\n",
332-
" \"ASK\": 1.1279,\n",
333-
" \"TIMACT\": \"12:16:00\"\n",
313+
" \"BID\": 1.1272,\n",
314+
" \"ASK\": 1.1275,\n",
315+
" \"TIMACT\": \"10:26:00\"\n",
334316
" }\n",
335317
"}\n"
336318
]
@@ -382,7 +364,7 @@
382364
},
383365
{
384366
"cell_type": "code",
385-
"execution_count": 9,
367+
"execution_count": 8,
386368
"metadata": {},
387369
"outputs": [],
388370
"source": [

‎Tutorials/3.Delivery/3.1-Streaming/TUT_3.1.02-OMMStream-MarketByPrice.ipynb‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -139,13 +139,13 @@
139139
"stream = omm_stream.Definition(name=\"VOD.L\", domain='MarketByPrice').get_stream()\n",
140140
"\n",
141141
"# Refresh - the first full imaage we get back from the server\n",
142-
"stream.on_refresh(lambda item_stream, event : display_event(\"Refresh\", event))\n",
142+
"stream.on_refresh(lambda stream, event : display_event(\"Refresh\", event))\n",
143143
"# Update - as and when field values change, we receive updates from the server\n",
144-
"stream.on_update(lambda item_stream, event : display_event(\"Update\", event))\n",
144+
"stream.on_update(lambda stream, event : display_event(\"Update\", event))\n",
145145
"# Status - if data goes stale or item closes, we get a status message\n",
146-
"stream.on_status(lambda item_stream, event : display_event(\"Status\", event))\n",
146+
"stream.on_status(lambda stream, event : display_event(\"Status\", event))\n",
147147
"# Other errors\n",
148-
"stream.on_error(lambda item_stream, event : display_event(\"Error\", event))"
148+
"stream.on_error(lambda stream, event : display_event(\"Error\", event))"
149149
]
150150
},
151151
{

0 commit comments

Comments
 (0)