This project us a simple RxJava wrapper for the Pusher Java Library, allowing you to use Pusher in your Android applications keeping your reactive workflow in place 🙌🏻

Functionality

Reactive-Pusher currently supports operations related to the subscription to public and private channels.

Connecting to pusher

You can use the observeConnection() method to observe the connection

reactivePusher.observeConnection().subscribe({
    when (it) {
        ConnectionStatus.CONNECTED -> { }
        ConnectionStatus.CONNECTING -> { }
        ConnectionStatus.DISCONNECTING -> { }
        ConnectionStatus.DISCONNECTED -> { }
        ConnectionStatus.RECONNECTING -> { }
        ConnectionStatus.UNKNOWN -> { }
    }
}))

There is also an observeConnection(varargs filter: String) that allows you to pass a collection of ConnectionEvents which you wish to exclude the callback being triggered.

Getting channels

You can retrieve channels using either the getChannel(), getPrivateChannel() or getPresenceChannel() methods.

reactivePusher.getChannel("some channel name")
    .subscribe({ // do something with the channel })

Checking channel subscription state

You can also use the isChannelSubscribed(), isPrivateChannelSubscribed() and isPresenceChannelSubscribed() methods to check the subscription state of a channel.

reactivePusher.isChannelSubscribed("some channel name")
    .subscribe({ // do something with the channel subscription result })

Subscribing to channels

Using the subscribeToChannel(), subscribeToPrivateChannel() or bindToPrivateChannelEvent() methods allow you to subscribe to events from a given channel.

When subscribed to a channel you need to pass a collection of events that you wish to subscribe to, when binding you only need to pass a single event that you wish to bind to.

When an event is received you will get an instance of a ChannelEvent from the callback.

reactivePusher.subscribeToChannel("some channel name")
    .subscribe({ // do something with the channel event })

Triggering events

You can also trigger events from this library by using the triggerEvent() method.

reactivePusher.triggerEvent("some channel name", "some event name", "some data")
    .subscribe({ // do something with the trigger completion })

Using the library

The library is still in development, so please use it as provided. Currently you need to use jitpack in order to use this library, which can be done by following the instructions at Jitpack