Refinitiv Data Library for Python

stream.on_update

Called when the status of one of the requested instruments changes.

Module

refinitiv.data.content.trade_data_service

Syntax

stream.on_event(func)

Parameters

Value Description Data type Optional Default value
func Callable object to process the retrieved data. Callable No -

Returned value

trade data service Stream object

Usage

The following example demonstrates how to display messages received when the status of one of the requested instruments changes.

def func(event, stream):
    current_time = datetime.datetime.now().time()
    print("----------------------------------------------------------")
    print(">>> {} event received at {}".format("Add", current_time))
    print(event)


stream = trade_data_service.Definition(
    universe="LSEG.L",
    fields=["OrderKey", "OrderTime"]
).get_stream()

stream.on_event(func)
stream.open()

None.