public class FlowableOnBackpressureBufferToFileTest extends Object
Constructor and Description |
---|
FlowableOnBackpressureBufferToFileTest() |
public FlowableOnBackpressureBufferToFileTest()
public void testJavaIOSerializable()
public void testJavaIOSerializableObservableSource()
public void testByteArrayLengthOne()
public void testByteArrays()
public void testEmpty()
public void testOne()
public void testOneWithSerializerThatReturnsNullAtSerialize()
public void testOneWithSerializerThatReturnsNullAtDeserialize()
public void testNullSubscriber()
public void testError()
public void testErrorObservable()
public void testItemsThenError()
public void testMessageCrossesPage()
public void testOneMessagePerPage()
public void testManyIntegers()
public void testVeryManyIntegers()
public void testVeryManyByteArrays()
public void testVeryManyByteArraysObservableSource()
public void testCancelDeletesPageFileWhenNoOutstandingRequests()
public void testFragments()
public void testFragmentsAsync()
public void testSynchronous()
public void testCancel() throws InterruptedException
InterruptedException
public void testCancelObservable() throws InterruptedException
InterruptedException
public void testVeryManyByteArraysBatchedRequests()
public void testVeryMany1KByteArrays()
public void testCloseQueue()
public void testCloseQueueThrowsExceptionReportsToPlugins()
public void testPollQueueThrowsExceptionEmitsError()
Copyright © 2013–2020. All rights reserved.