ObjectStoreSubscriptionStreamReader
ObjectStoreSubscriptionStreamReader(
object_store: IObjectStore, key: str
)
Bases: Object, IStreamReader
Represents a stream reader capable of reading lines from the object store
Initializes a new instance of the ObjectStoreSubscriptionStreamReader class.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
object_store
|
IObjectStore
|
The IObjectStore used to retrieve a stream of data |
required |
key
|
str
|
The object store key the data should be fetched from |
required |
should_be_rate_limited: bool
Gets whether or not this stream reader should be rate limited
stream_reader: StreamReader
Direct access to the StreamReader instance
transport_medium: SubscriptionTransportMedium
Gets SubscriptionTransportMedium.LOCAL_FILE
end_of_stream: bool
Gets whether or not there's more data to be read in the stream
dispose() -> None
Disposes of the stream
read_line() -> str
Gets the next line/batch of content from the stream