FirehoseMessageHandler typedef

FirehoseMessageHandler = FutureOr<void> Function(USyncSubscribeReposMessage message)

Handles one firehose message.

The returned future's completion is what advances the cursor, so a handler that persists must not complete before that write does. Throwing is tolerated (see Firehose.start).

Implementation

typedef FirehoseMessageHandler =
    FutureOr<void> Function(USyncSubscribeReposMessage message);