stream<T> method

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

Implementation

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