diff options
Diffstat (limited to 'docs/streaming-custom-receivers.md')
| -rw-r--r-- | docs/streaming-custom-receivers.md | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/streaming-custom-receivers.md b/docs/streaming-custom-receivers.md index 4e27d6559c..3fb540c9fb 100644 --- a/docs/streaming-custom-receivers.md +++ b/docs/streaming-custom-receivers.md @@ -14,7 +14,7 @@ This starts with implementing [NetworkReceiver](api/streaming/index.html#org.apa The following is a simple socket text-stream receiver. {% highlight scala %} - class SocketTextStreamReceiver(host: String, port: Int( + class SocketTextStreamReceiver(host: String, port: Int) extends NetworkReceiver[String] { protected lazy val blocksGenerator: BlockGenerator = |