code: public void dispose() {
          if (onSubscribe.disposed.compareAndSet(false, true)) {
              for (Object chunk : onSubscribe.chunks) {
                  ReferenceCountUtil.release(chunk);
              }
              onSubscribe.chunks.clear();
          }
      }
docs: Disposes this source.