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