stream<T> method

Future<XRPCResponse<Subscription<T>>> stream<T>(
  1. NSID methodId, {
  2. Map<String, dynamic>? parameters,
  3. ResponseDataBuilder<T>? to,
  4. ResponseDataAdaptor? adaptor,
})

Implementation

Future<xrpc.XRPCResponse<xrpc.Subscription<T>>> stream<T>(
  final NSID methodId, {
  final Map<String, dynamic>? parameters,
  final xrpc.ResponseDataBuilder<T>? to,
  final xrpc.ResponseDataAdaptor? adaptor,
}) async => await _challenge.execute(
  () => xrpc.subscribe(
    methodId,
    service: relayService,
    parameters: parameters,
    to: to,
    adaptor: adaptor,
  ),
);