Class NettyStreamingService.Subscription

java.lang.Object
info.bitrich.xchangestream.service.netty.NettyStreamingService.Subscription
Enclosing class:
NettyStreamingService<T>

protected class NettyStreamingService.Subscription extends Object
  • Constructor Details

    • Subscription

      public Subscription(io.reactivex.rxjava3.core.ObservableEmitter<T> emitter, String channelName, Object[] args)
  • Method Details

    • getEmitter

      public io.reactivex.rxjava3.core.ObservableEmitter<T> getEmitter()