au.gov.amsa.streams

Class StringServer

java.lang.Object

au.gov.amsa.streams.StringServer

public final class StringServer
extends Object

Publishes lines from an Observable<String> source to a ServerSocket.

Method Summary

Modifier and Type	Method and Description
static StringServer	create(rx.Observable<String> source, int port) Factory method.
void	start() Starts the server.
void	stop() Stops the server by closing the ServerSocket.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

create

public static StringServer create(rx.Observable<String> source,
                                  int port)

Factory method.

Parameters:

source - source to publish on server socket

port - to assign the server socket to

start

public void start()

Starts the server. Each connection to the server will bring about another subscription to the source.

stop

public void stop()

Stops the server by closing the ServerSocket.

toString

public String toString()

Overrides:

toString in class Object