class Crabbit::SuperStreamPublishHandle

• Crabbit::SuperStreamPublishHandle
• Reference
• Object

Overview

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.

Defined in:

crabbit/super_stream.cr

Instance Method Summary

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

  Waits for every partition confirmation within one shared timeout.

• #completed? : Bool

  Returns whether every partition publish has completed.

• #handles : Array(PublishHandle)

  Returns the partition publish handles.

• #on_confirm(&callback : Confirmation -> ) : self

  Registers callback on every partition publish and returns self.

Instance Method Detail