Packages  ›  trotsky  ›  StepStreamPosts

StepStreamPosts class

Represents a streaming step that processes posts in real-time.

Signature:

export declare class StepStreamPosts<P, C = unknown, O = StepPostOutput> extends StepBuilderStream<P, C, O>

Extends: StepBuilderStream<P, C, O>

Remarks

This class allows for the streaming and processing of posts as they are committed to the network. To achieve this, it utilizes the Bluesky Firehose API to listen for post events and process them in real-time. The stream can use a lot of bandwidth since it processes every post event.

Properties

Property	Modifiers	Type	Description
_steps		StepPostsEntry<this>[]

Methods

Method	Modifiers	Description
buildEventEmitter()		Builds and returns an event emitter configured for post events.
each()		Adds a StepPostsEntry step to the stream.
resolveOutput(message)		Resolves the output for a given commit message.