open_hypersync_stream

Documentation for eth_defi.hypersync.session.open_hypersync_stream function.

async open_hypersync_stream(client, query)

Open a Hypersync stream, dispatching correctly for both client types.

For ThrottledHypersyncClient, calls stream(query) which builds a hypersync.StreamConfig from stored tuning parameters and logs them.

For a native hypersync.HypersyncClient, passes a bare StreamConfig() with all server defaults.

Use this instead of calling client.stream(query, config) directly so that tuning parameters are applied transparently.

Parameters
Return type

hypersync.QueryResponseStream