Refinitiv Data Library for Python

trade data service stream.on_remove

Called when the stream on summary order of instruments is removed by the server.

Module

refinitiv.data.content.trade_data_service

Syntax

stream.on_remove(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 stream on the summary order of the instruments is removed by the server.

import datetime


# previously defined callable, pay attention that arguments order is important
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_remove(func)
stream.open()

None.