Stack Overflow
Stack Overflow

Questions tagged [subscriber]

272 questions
24
votes
1 answer

Why RxJava with Retrofit on Android doOnError() does not work but Subscriber onError does

can someone explain me why code like this: networApi.getList() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .doOnError(throwable -> { throwable.getMessage(); …
wojciech_maciejewski
  • 1,277
  • 1
  • 12
  • 28
15
votes
3 answers

How to run 2 queries sequentially in a Android RxJava Observable?

I want to run 2 asynchronous tasks, one followed by the other (sequentially). I have read something about ZIP or Flat, but I didn't understand it very well... My purpose is to load the data from a Local SQLite, and when it finishes, it calls the…
Jaume Colom Ferrer
  • 559
  • 1
  • 5
  • 14
13
votes
1 answer

Java 9 - how publisher and subscriber works

I am trying to understand how Subscriber and Publisher works in java 9. Here I have created one subscriber here and using SubmissionPublisher for publishing item . I am trying to publish 100 strings to subscriber. If I do not make the Client program…
Shiva
  • 1,962
  • 2
  • 13
  • 31
11
votes
1 answer

iPad Newsstand Subscriber Information (name, email, zip)

When users purchase a magazine subscription on my iPad Newsstand app they get prompted to share some info: Share your Information? The publisher of [app name here] would like your name, email, and zip code for use in accordance with their privacy…
user628896
  • 225
  • 2
  • 9
10
votes
3 answers

How do I use the subscriber option?

I started now with Pubsubhubbub (and all about realtime things), but I amhaving trouble with the Subscriber option. I'm trying to develop a webapp in PHP to: Subscribe a RSS (previously Published) to the Hub (http://pubsubhubbub.appspot.com/); Read…
ddluis
  • 101
  • 1
  • 5
9
votes
3 answers

Set subscriber status in Magento programmatically

I am trying to write a module that syncs my newsletter subscribers in Magento with a external database. I need to be able to update the subscription status in Magento programmatically but I am having diffuculty getting the "setStatus" method in…
Chuck D
  • 1,718
  • 4
  • 19
  • 26
8
votes
3 answers

ROS Image subscriber lag

I am having some lag issues with a rospy subscriber listening to image messages. Overview: I have a rosbag streaming images to /camera/image_raw at 5Hz. I also have an image_view node for displaying the images for reference. This image_view shows…
sr71
  • 81
  • 1
  • 3
8
votes
1 answer

SQL Server 2005 Replication and different indexes on the subscriber

We have SQL Server database setup. We are setting up a replication scenarios where we have one publisher and on subscriber. The subscriber will be used as a reporting platform so that we can run all the BI queries that we need and have to hit the…
Kinlan
  • 16,315
  • 5
  • 56
  • 88
7
votes
2 answers

How to unit test code inside subscribe for Angular7 unit test case

I want to unit test and get coverage for all code but i am not able to get coverage for code present inside subscribe I am able to spy service and function but inside subscribe i am not able to unit test and get code coverage . following is Angular…
Roshni joshi
  • 88
  • 1
  • 2
  • 7
7
votes
1 answer

get youtube channel subscribers via youtube API

I'm trying to use youtube api to get a list of subscribers to a channel i own then check a user's Email to find out if he's subscribed or not. Now I'm using this page to test my first step…
PHP User
  • 2,350
  • 6
  • 46
  • 87
6
votes
1 answer

Reason to set queue size of ROS publisher or subscriver to a large value

When I look over the tutorial of Robot Operating system (ROS), I found most example codes set the publisher's queue size to a larger value such as 1000. I think this leads to losing real-time response of the node. For what purpose, do people set it…
orematasaburo
  • 1,207
  • 10
  • 20
6
votes
2 answers

Cannot read property 'isStopped' of undefined [Angular2]

I'm trying to use an observable for my service in Angular 2. But I'm receiving this error: Uncaught TypeError: Cannot read property 'isStopped' of undefined A sneak peek of my service: import { Observable } from 'rxjs/Observable'; import {…
Gaspar Err.
  • 133
  • 1
  • 8
5
votes
4 answers

Google pubsub golang subscriber stops receiving new published message(s) after being idle for a few hours

I created a TOPIC in google pubsub, and created a SUBSCRIPTION inside the TOPIC, with the following settings then I wrote a puller in go, using its Receive to pull and acknowledge published messages package main import ( ... ) func main() { …
littlechad
  • 1,202
  • 17
  • 48
5
votes
5 answers

Rxjava: Subscribe on the specific thread

I'm a newbie in Rxjava. I have the following code: System.out.println("1: " + Thread.currentThread().getId()); Observable.create(new rx.Observable.OnSubscribe() { @Override public void call(Subscriber…
Meo Beo
  • 474
  • 2
  • 7
  • 17
5
votes
4 answers

Ros subscriber not up to date

I have written a ROS subscriber to one of the image topics and I have set my buffer to 1 using: subscriber =rospy.Subscriber("/camera/rgb/image_mono/compressed",CompressedImage, callback, queue_size=1) However my subscriber still lags behind. Any…
Sello Mkantjwa
  • 1,798
  • 1
  • 20
  • 36
1
2 3
…
18 19