subscribeRepos method

Future<XRPCResponse<Subscription<USubscribeReposMessage>>> subscribeRepos({
  1. int? cursor,
  2. Map<String, dynamic>? $unknown,
})

Repository event stream, aka Firehose endpoint. Outputs repo commits with diff data, and identity update events, for all repositories on the current server. See the atproto specifications for details around stream sequencing, repo versioning, CAR diff format, and more. Public and does not require auth; implemented by PDS and Relay.

https://atprotodart.com/docs/lexicons/com/atproto/sync/subscribeRepos

Implementation

Future<XRPCResponse<Subscription<USubscribeReposMessage>>> subscribeRepos({
  int? cursor,
  Map<String, dynamic>? $unknown,
}) async =>
    await _ctx.stream(
      ns.comAtprotoSyncSubscribeRepos,
      parameters: {
        if (cursor != null) 'cursor': cursor,
        ...?$unknown,
      },
      adaptor: subscribeReposAdaptor,
      to: const USubscribeReposMessageConverter().fromJson,
    );