FlowableOnBackpressureBufferToFileTest (rxjava2-extras 0.1.38 Test API)

java.lang.Object
- com.github.davidmoten.rx2.buffertofile.FlowableOnBackpressureBufferToFileTest

public class FlowableOnBackpressureBufferToFileTest
extends Object

Constructor Summary

Constructors
Constructor and Description

FlowableOnBackpressureBufferToFileTest()

Constructors
Constructor and Description
`FlowableOnBackpressureBufferToFileTest()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`testByteArrayLengthOne()`
`void`	`testByteArrays()`
`void`	`testCancel()`
`void`	`testCancelDeletesPageFileWhenNoOutstandingRequests()`
`void`	`testCancelObservable()`
`void`	`testCloseQueue()`
`void`	`testCloseQueueThrowsExceptionReportsToPlugins()`
`void`	`testEmpty()`
`void`	`testError()`
`void`	`testErrorObservable()`
`void`	`testFragments()`
`void`	`testFragmentsAsync()`
`void`	`testItemsThenError()`
`void`	`testJavaIOSerializable()`
`void`	`testJavaIOSerializableObservableSource()`
`void`	`testManyIntegers()`
`void`	`testMessageCrossesPage()`
`void`	`testNullSubscriber()`
`void`	`testOne()`
`void`	`testOneMessagePerPage()`
`void`	`testOneWithSerializerThatReturnsNullAtDeserialize()`
`void`	`testOneWithSerializerThatReturnsNullAtSerialize()`
`void`	`testPollQueueThrowsExceptionEmitsError()`
`void`	`testSynchronous()`
`void`	`testVeryMany1KByteArrays()`
`void`	`testVeryManyByteArrays()`
`void`	`testVeryManyByteArraysBatchedRequests()`
`void`	`testVeryManyByteArraysObservableSource()`
`void`	`testVeryManyIntegers()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- FlowableOnBackpressureBufferToFileTest
```
public FlowableOnBackpressureBufferToFileTest()
```

Method Detail

testJavaIOSerializable
```
public void testJavaIOSerializable()
```

testJavaIOSerializableObservableSource

public void testJavaIOSerializableObservableSource()

testByteArrayLengthOne
```
public void testByteArrayLengthOne()
```

testByteArrays
```
public void testByteArrays()
```

testEmpty
```
public void testEmpty()
```

testOne
```
public void testOne()
```

testOneWithSerializerThatReturnsNullAtSerialize

public void testOneWithSerializerThatReturnsNullAtSerialize()

testOneWithSerializerThatReturnsNullAtDeserialize

public void testOneWithSerializerThatReturnsNullAtDeserialize()

testNullSubscriber
```
public void testNullSubscriber()
```

testError
```
public void testError()
```

testErrorObservable
```
public void testErrorObservable()
```

testItemsThenError
```
public void testItemsThenError()
```

testMessageCrossesPage
```
public void testMessageCrossesPage()
```

testOneMessagePerPage
```
public void testOneMessagePerPage()
```

testManyIntegers
```
public void testManyIntegers()
```

testVeryManyIntegers
```
public void testVeryManyIntegers()
```

testVeryManyByteArrays
```
public void testVeryManyByteArrays()
```

testVeryManyByteArraysObservableSource

public void testVeryManyByteArraysObservableSource()

testCancelDeletesPageFileWhenNoOutstandingRequests

public void testCancelDeletesPageFileWhenNoOutstandingRequests()

testFragments
```
public void testFragments()
```

testFragmentsAsync
```
public void testFragmentsAsync()
```

testSynchronous
```
public void testSynchronous()
```

testCancel

public void testCancel()
                throws InterruptedException

Throws:: InterruptedException

testCancelObservable

public void testCancelObservable()
                          throws InterruptedException

Throws:: InterruptedException

testVeryManyByteArraysBatchedRequests

public void testVeryManyByteArraysBatchedRequests()

testVeryMany1KByteArrays

public void testVeryMany1KByteArrays()

testCloseQueue
```
public void testCloseQueue()
```

testCloseQueueThrowsExceptionReportsToPlugins

public void testCloseQueueThrowsExceptionReportsToPlugins()

testPollQueueThrowsExceptionEmitsError

public void testPollQueueThrowsExceptionEmitsError()

Class FlowableOnBackpressureBufferToFileTest

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

FlowableOnBackpressureBufferToFileTest

Method Detail

testJavaIOSerializable

testJavaIOSerializableObservableSource

testByteArrayLengthOne

testByteArrays

testEmpty

testOne

testOneWithSerializerThatReturnsNullAtSerialize

testOneWithSerializerThatReturnsNullAtDeserialize

testNullSubscriber

testError

testErrorObservable

testItemsThenError

testMessageCrossesPage

testOneMessagePerPage

testManyIntegers

testVeryManyIntegers

testVeryManyByteArrays

testVeryManyByteArraysObservableSource

testCancelDeletesPageFileWhenNoOutstandingRequests

testFragments

testFragmentsAsync

testSynchronous

testCancel

testCancelObservable

testVeryManyByteArraysBatchedRequests

testVeryMany1KByteArrays

testCloseQueue

testCloseQueueThrowsExceptionReportsToPlugins

testPollQueueThrowsExceptionEmitsError