Just a note: for your code examples, you posted the publisher twice (I think the second one is supposed to be the code for the consumer).