@Test(timeout = 60000) public void testAutoRelease() throws Exception { ContentSource<ByteBuf> source = new ContentSource<>(sourceRule.getChannel(), sourceRule); sourceRule.subscribe(source.autoRelease(), 0); }
public Observable<T> autoRelease() { return this.lift(new AutoReleaseOperator<T>()); }
ContentSource extends Observable<T> { public Observable<T> autoRelease() { return this.lift(new AutoReleaseOperator<T>()); } }
ContentSource extends Observable<T> { public Observable<T> autoRelease() { return this.lift(new AutoReleaseOperator<T>()); } private  ContentSource(final Observable<T> source);  ContentSource(final Channel channel, final Func1<Subscriber<? super T>, Object> subscriptionEventFactory);  ContentSource(final Throwable error); }
ContentSource extends Observable<T> { public Observable<T> autoRelease() { return this.lift(new AutoReleaseOperator<T>()); } private  ContentSource(final Observable<T> source);  ContentSource(final Channel channel, final Func1<Subscriber<? super T>, Object> subscriptionEventFactory);  ContentSource(final Throwable error); Observable<T> autoRelease(); DisposableContentSource<T> replayable(); ContentSource<R> transform(Transformer<T, R> transformer); }
ContentSource extends Observable<T> { public Observable<T> autoRelease() { return this.lift(new AutoReleaseOperator<T>()); } private  ContentSource(final Observable<T> source);  ContentSource(final Channel channel, final Func1<Subscriber<? super T>, Object> subscriptionEventFactory);  ContentSource(final Throwable error); Observable<T> autoRelease(); DisposableContentSource<T> replayable(); ContentSource<R> transform(Transformer<T, R> transformer);  }