gistfile1.java

return PublisherFactory.create(
					(n, s) -> {
						long i = 0l;
						while (i < n && s.context().get() < elements) {
							if(s.isCancelled()) return;

							s.onNext(s.context().getAndIncrement());
							i++;
						}
						if(s.context().get() == elements){
							s.onComplete();
						}
					},
					s -> new AtomicLong(0L)
			);