Class NettyStreamingService.Subscription

    • Constructor Detail

      • Subscription

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

      • getEmitter

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