FirehoseConnector typedef

FirehoseConnector = Future<FirehoseConnection> Function(int? cursor)

Opens a firehose subscription starting after cursor, or from the live edge when it is null.

Injectable so tests can drive the reconnect loop, and the cursor handling that rides on it, without a live socket.

Implementation

typedef FirehoseConnector = Future<FirehoseConnection> Function(int? cursor);