Package info.bitrich.xchangestream.service.pubnub

Class PubnubStreamingService

java.lang.Object
info.bitrich.xchangestream.service.pubnub.PubnubStreamingService
public class PubnubStreamingService extends Object
Created by Lukas Zaoralek on 14.11.17.

  • Constructor Details

    • PubnubStreamingService

      public PubnubStreamingService(String publicKey)

  • Method Details

    • connect

      public io.reactivex.rxjava3.core.Completable connect()

    • subscribeChannel

      public io.reactivex.rxjava3.core.Observable<com.fasterxml.jackson.databind.JsonNode> subscribeChannel(String channelName)

    • disconnect

      public io.reactivex.rxjava3.core.Completable disconnect()

    • isAlive

      public boolean isAlive()

    • useCompressedMessages

      public void useCompressedMessages(boolean compressedMessages)