diff --git a/docs/streaming-custom-receivers.md b/docs/streaming-custom-receivers.md index 4e27d6559cf1e5673c3e1012be807bbe2e10d05a..3fb540c9fb560f42d4cc12c1f4cc89bfd7f6f92c 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 =