Package info.bitrich.xchangestream.serum

Class SerumSubscriptionManager

java.lang.Object
info.bitrich.xchangestream.serum.SerumSubscriptionManager
public class SerumSubscriptionManager extends Object

  • Constructor Details

    • SerumSubscriptionManager

      public SerumSubscriptionManager()

  • Method Details

    • newSubscription

      public void newSubscription(int reqID, int subID)
      Modifies maps to add a new subscription confirmed by Solana
      Parameters:
      reqID - used in subscription
      subID - assigned by Solana to track the channel

    • removedSubscription

      public void removedSubscription(int reqID, boolean status)
      Modifies maps to remove subscriptions we have unsubscribed from
      Parameters:
      reqID - used in subscription
      status - of unsubscription

    • getChannelName

      public String getChannelName(int subID)

    • generateNewInflightRequest

      public int generateNewInflightRequest(String channelName)