Constructors
constructor
• new StreamClient(client): StreamClient
Parameters
| Name | Type |
|---|---|
client | Client |
Returns
StreamClient
Defined in
stream/stream_client.ts:560Methods
postsFirehoseJa
▸ postsFirehoseJa(partition, options?): Promise<EventDrivenStream>
Stream Japanese Posts
Streams all public Japanese-language Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsFirehoseJaStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:580posts
▸ posts(options?): Promise<EventDrivenStream>
Stream filtered Posts
Streams Posts in real-time matching the active rule set.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type |
|---|---|
options | PostsStreamingOptions |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:710postsSample10
▸ postsSample10(partition, options?): Promise<EventDrivenStream>
Stream 10% sampled Posts
Streams a 10% sample of public Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsSample10StreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:839likesFirehose
▸ likesFirehose(partition, options?): Promise<EventDrivenStream>
Stream all Likes
Streams all public Likes in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | LikesFirehoseStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:973likesCompliance
▸ likesCompliance(options?): Promise<EventDrivenStream>
Stream Likes compliance data
Streams all compliance data related to Likes for Users.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type |
|---|---|
options | LikesComplianceStreamingOptions |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1094postsFirehoseEn
▸ postsFirehoseEn(partition, options?): Promise<EventDrivenStream>
Stream English Posts
Streams all public English-language Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsFirehoseEnStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1189postsCompliance
▸ postsCompliance(partition, options?): Promise<EventDrivenStream>
Stream Posts compliance data
Streams all compliance data related to Posts.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsComplianceStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1323postsFirehose
▸ postsFirehose(partition, options?): Promise<EventDrivenStream>
Stream all Posts
Streams all public Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsFirehoseStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1421likesSample10
▸ likesSample10(partition, options?): Promise<EventDrivenStream>
Stream sampled Likes
Streams a 10% sample of public Likes in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | LikesSample10StreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1555postsFirehosePt
▸ postsFirehosePt(partition, options?): Promise<EventDrivenStream>
Stream Portuguese Posts
Streams all public Portuguese-language Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsFirehosePtStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1680postsFirehoseKo
▸ postsFirehoseKo(partition, options?): Promise<EventDrivenStream>
Stream Korean Posts
Streams all public Korean-language Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | PostsFirehoseKoStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1814labelsCompliance
▸ labelsCompliance(options?): Promise<EventDrivenStream>
Stream Post labels
Streams all labeling events applied to Posts.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type |
|---|---|
options | LabelsComplianceStreamingOptions |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:1944usersCompliance
▸ usersCompliance(partition, options?): Promise<EventDrivenStream>
Stream Users compliance data
Streams all compliance data related to Users.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type | Description |
|---|---|---|
partition | number | The partition number. |
options | UsersComplianceStreamingOptions | - |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:2039postsSample
▸ postsSample(options?): Promise<EventDrivenStream>
Stream sampled Posts
Streams a 1% sample of public Posts in real-time.
Returns an event-driven stream that’s easy to use.
Use .on() to listen for events like ‘data’, ‘error’, ‘close’.
Also supports async iteration with for await…of.
Parameters
| Name | Type |
|---|---|
options | PostsSampleStreamingOptions |
Returns
Promise<EventDrivenStream>
Event-driven stream for handling streaming data
Defined in
stream/stream_client.ts:2133getRuleCounts
▸ getRuleCounts(options?): Promise<Get2TweetsSearchStreamRulesCountsResponse>
Get stream rule counts
Retrieves the count of rules in the active rule set for the filtered stream.
Parameters
| Name | Type |
|---|---|
options | GetRuleCountsStreamingOptions |
Returns
Promise<Get2TweetsSearchStreamRulesCountsResponse>
Promise with the API response
Defined in
stream/stream_client.ts:2242getRules
▸ getRules(options?): Promise<RulesLookupResponse>
Get stream rules
Retrieves the active rule set or a subset of rules for the filtered stream.
Parameters
| Name | Type |
|---|---|
options | GetRulesStreamingOptions |
Returns
Promise<RulesLookupResponse>
Promise with the API response
Defined in
stream/stream_client.ts:2299updateRules
▸ updateRules(body, options?): Promise<AddOrDeleteRulesResponse>
Update stream rules
Adds or deletes rules from the active rule set for the filtered stream.
Parameters
| Name | Type |
|---|---|
body | any |
options | UpdateRulesStreamingOptions |
Returns
Promise<AddOrDeleteRulesResponse>
Promise with the API response