tensortrade.feed.core.feed module

class tensortrade.feed.core.feed.DataFeed(*args, **kwargs)

Bases: Stream[dict]

A stream the compiles together streams to be run in an organized manner.

Parameters:

streams (List[Stream]) – A list of streams to be used in the data feed.

compile() → None

Compiles all the given stream together.

Organizes the order in which streams should be run to get valid output.

forward() → dict

Generates the next value from the underlying data streams.

Returns:

T – The next value in the stream.

has_next() → bool

Checks if there is another value.

Returns:

bool – If there is another value or not.

next() → dict

reset(random_start=0) → None

Resets all inputs to and listeners of the stream and sets stream value to None.

run() → None

Runs all the streams in processing order.

class tensortrade.feed.core.feed.PushFeed(*args, **kwargs)

Bases: DataFeed

A data feed for working with live data in an online manner.

All sources of data to be used with this feed must be a Placeholder. This ensures that the user can wait until all of their data has been loaded for the next time step.

Parameters:

streams (List[Stream]) – A list of streams to be used in the data feed.

property is_loaded

next() → dict

push(data: dict) → dict

Generates the values from the data feed based on the values being provided in data.

Parameters:

data (dict) – The data to be pushed to each of the placholders in the feed.

Returns:

dict – The next data point generated from the feed based on data.