BaseClient constructor

BaseClient(
  1. StreamChannel channel, {
  2. ErrorCallback? onUnhandledError,
})

Implementation

BaseClient(StreamChannel channel, {rpc.ErrorCallback? onUnhandledError}) {
  peer = rpc.Peer.withoutJson(channel,
      onUnhandledError: onUnhandledError ?? handleError);
  unawaited(peer.listen());
}