class

Crabbit::SuperStreamPublishHandle

Inherits Reference < Object

Aggregate confirmation handle for a super-stream publish.

Most routing strategies select one partition, but a custom strategy can publish to several. This handle exposes one PublishHandle per selected partition.

Instance methods

await(timeout : Time::Span = 30.seconds) : Array(Confirmation)

Waits for every partition confirmation within one shared timeout.

Source
completed?

Returns whether every partition publish has completed.

Source
handles

Returns the partition publish handles.

Source
on_confirm

Registers callback on every partition publish and returns self.

Source