A implementation of a PushProcessor that should live as a singleton by being installed in the Application’s onCreate. It receives messages from a service and forwards them to be decrypted and routed.
Listen for subscription information changes for each registered scope:
Listen also for push messages:
Observers that want to receive updates for new subscriptions and messages.
| Name | Summary |
| <init> |
AutoPushFeature(context: <ERROR CLASS>, service:
= Executors.newSingleThreadExecutor().asCoroutineDispatcher(), connection:
senderId = config.senderId,
serverHost = config.serverHost,
socketProtocol = config.protocol,
serviceType = config.serviceType,
databasePath = File(context.filesDir, DB_NAME).canonicalPath
? = null)
A implementation of a PushProcessor that should live as a singleton by being installed in the Application’s onCreate. It receives messages from a service and forwards them to be decrypted and routed. |
Checks if a subscription for the scope already exists.
Starts the push feature and initialization work needed. Also starts the PushService to ensure new messages come through.
An error has occurred.
New encrypted messages received from a supported push messaging service.
New registration tokens are received and sent to the AutoPush server which also performs subscriptions for each push type and notifies the subscribers.
Deletes the registration token locally so that it forces the service to get a new one the next time hits it’s messaging server.
Un-subscribes from all push message channels and stops periodic verifications.
Subscribes for push notifications and invokes the onSubscribe callback with the subscription information.
Un-subscribes from a valid subscription and invokes the onUnsubscribe callback with the result.
Loads a file from the resources folder and returns its content as a string object.