com.github.davidmoten.rx2.internal.flowable

Class FlowableServerSocketTest

java.lang.Object

com.github.davidmoten.rx2.internal.flowable.FlowableServerSocketTest

public final class FlowableServerSocketTest
extends Object

Constructor Summary

Constructors

Constructor and Description
FlowableServerSocketTest()

Method Summary

Modifier and Type	Method and Description
void	errorEmittedIfServerSocketBusy()
void	isUtilityClass()
void	isUtilityClassIO()
static void	main(String[] args)
void	serverSocketReadsTcpPushWhenBufferIsBiggerThanInput()
void	serverSocketReadsTcpPushWhenBufferIsSameSizeAsInput()
void	serverSocketReadsTcpPushWhenBufferIsSmallerThanInput()
void	serverSocketReadsTcpPushWhenInputIsEmpty()
void	serverSocketReadsTcpPushWhenInputIsOneCharacter()
void	testAcceptSocketRejectsAlways()
void	testCancelDoesNotHaveToWaitForTimeout()
void	testCloseQuietly()
void	testCloserWhenDoesNotThrow()
void	testCloserWhenThrows()
void	testEarlyUnsubscribe()
void	testLoad()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowableServerSocketTest

public FlowableServerSocketTest()

Method Detail

testCloseQuietly

public void testCloseQuietly()

serverSocketReadsTcpPushWhenBufferIsSmallerThanInput

public void serverSocketReadsTcpPushWhenBufferIsSmallerThanInput()
                                                          throws UnknownHostException,
                                                                 IOException,
                                                                 InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

serverSocketReadsTcpPushWhenBufferIsBiggerThanInput

public void serverSocketReadsTcpPushWhenBufferIsBiggerThanInput()
                                                         throws UnknownHostException,
                                                                IOException,
                                                                InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

serverSocketReadsTcpPushWhenBufferIsSameSizeAsInput

public void serverSocketReadsTcpPushWhenBufferIsSameSizeAsInput()
                                                         throws UnknownHostException,
                                                                IOException,
                                                                InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

serverSocketReadsTcpPushWhenInputIsEmpty

public void serverSocketReadsTcpPushWhenInputIsEmpty()
                                              throws UnknownHostException,
                                                     IOException,
                                                     InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

serverSocketReadsTcpPushWhenInputIsOneCharacter

public void serverSocketReadsTcpPushWhenInputIsOneCharacter()
                                                     throws UnknownHostException,
                                                            IOException,
                                                            InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

errorEmittedIfServerSocketBusy

public void errorEmittedIfServerSocketBusy()
                                    throws IOException

Throws:

IOException

isUtilityClass

public void isUtilityClass()

isUtilityClassIO

public void isUtilityClassIO()

testCloserWhenDoesNotThrow

public void testCloserWhenDoesNotThrow()
                                throws Exception

Throws:

Exception

testCloserWhenThrows

public void testCloserWhenThrows()

testEarlyUnsubscribe

public void testEarlyUnsubscribe()
                          throws UnknownHostException,
                                 IOException,
                                 InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

testCancelDoesNotHaveToWaitForTimeout

public void testCancelDoesNotHaveToWaitForTimeout()
                                           throws UnknownHostException,
                                                  IOException,
                                                  InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

testLoad

public void testLoad()
              throws InterruptedException

Throws:

InterruptedException

testAcceptSocketRejectsAlways

public void testAcceptSocketRejectsAlways()
                                   throws UnknownHostException,
                                          IOException,
                                          InterruptedException

Throws:

UnknownHostException

IOException

InterruptedException

main

public static void main(String[] args)
                 throws InterruptedException

Throws:

InterruptedException