StreamRequest.deserialize constructor

StreamRequest.deserialize(List<int> bytes)

Implementation

factory StreamRequest.deserialize(List<int> bytes) {
  final decode = CosmosProtoMessage.decode(bytes, protoConfigStatic());
  return StreamRequest(
    bankBalancesFilter: decode.messageTo<BankBalancesFilter?>(
      1,
      (b) => BankBalancesFilter.deserialize(b),
    ),
    subaccountDepositsFilter: decode.messageTo<SubaccountDepositsFilter?>(
      2,
      (b) => SubaccountDepositsFilter.deserialize(b),
    ),
    spotTradesFilter: decode.messageTo<TradesFilter?>(
      3,
      (b) => TradesFilter.deserialize(b),
    ),
    derivativeTradesFilter: decode.messageTo<TradesFilter?>(
      4,
      (b) => TradesFilter.deserialize(b),
    ),
    spotOrdersFilter: decode.messageTo<OrdersFilter?>(
      5,
      (b) => OrdersFilter.deserialize(b),
    ),
    derivativeOrdersFilter: decode.messageTo<OrdersFilter?>(
      6,
      (b) => OrdersFilter.deserialize(b),
    ),
    spotOrderbooksFilter: decode.messageTo<OrderbookFilter?>(
      7,
      (b) => OrderbookFilter.deserialize(b),
    ),
    derivativeOrderbooksFilter: decode.messageTo<OrderbookFilter?>(
      8,
      (b) => OrderbookFilter.deserialize(b),
    ),
    positionsFilter: decode.messageTo<PositionsFilter?>(
      9,
      (b) => PositionsFilter.deserialize(b),
    ),
    oraclePriceFilter: decode.messageTo<OraclePriceFilter?>(
      10,
      (b) => OraclePriceFilter.deserialize(b),
    ),
    orderFailuresFilter: decode.messageTo<OrderFailuresFilter?>(
      11,
      (b) => OrderFailuresFilter.deserialize(b),
    ),
    conditionalOrderTriggerFailuresFilter: decode
        .messageTo<ConditionalOrderTriggerFailuresFilter?>(
          12,
          (b) => ConditionalOrderTriggerFailuresFilter.deserialize(b),
        ),
  );
}