streaming

class DistributedHTTPSink extends Sink with Logging with Serializable
class DistributedHTTPSinkProvider extends StreamSinkProvider with DataSourceRegister
class DistributedHTTPSource extends Source with Logging with Serializable
class DistributedHTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging
class HTTPSink extends Sink with Logging
class HTTPSinkProvider extends StreamSinkProvider with DataSourceRegister
class HTTPSource extends Source with Logging

A source that reads text lines through a TCP socket, designed only for tutorials and debugging.
A source that reads text lines through a TCP socket, designed only for tutorials and debugging. This source will *not* work in production applications due to multiple reasons, including no support for fault recovery and keeping all of the text read in memory forever.
class HTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging
class JVMSharedServer extends Logging
class MultiChannelMap[K, V] extends AnyRef